,hy:ddlmZddlZddlZddlZddlmZddlmZm Z m Z ddl m Z ddl mZmZmZmZmZmZddlmZddlZede d ef Zed Zed Zer=ddlZdd lmZmZddl m!Z!m"Z"m#Z#m$Z$ejJdkrddl&m'Z'e!dZ(e#dZ)d(dZ* d)dZ+GddZ, d*dZ- d+dZ.GddeeZ/d,dZ0d-dZ1erddl mZne1ZeGddeZ2d.d Z3ered!e d e4f Z5 d/ d0d"Z6ndd#l m6Z6d1d$Z7Gd%d&e8Z9 d2d'Z:y)3) annotationsN)ABCMeta) AwaitableCallableSequence)update_wrapper) TYPE_CHECKINGAnyGenericNoReturnTypeVarfinal) thread_localCallT.)boundTRetT)AsyncGeneratorType TracebackType) ParamSpecSelf TypeVarTupleUnpack) )BaseExceptionGroupArgsTPosArgsTc tjtjtjtjy#ttf$rYywxYw)z7Attempt to reliably check if we are in the main thread.TF)signalSIGINT getsignal TypeError ValueErrorL/var/www/html/Resume-Scraper/venv/lib/python3.12/site-packages/trio/_util.pyis_main_threadr(1sB fmmV%5%5fmm%DE z "sAAAAcdd}tjdc}t_ ||} |t_t|tj j s_||rtd |d tj|rtd |td jt|d||S#t$rt|tj j rT|jtd|d|jd|jd|jd|jd d||rtd |d dwxYw#|t_wxYw)Nct|tjjryt |ddy|j j dvS)NT_asyncio_future_blocking)FutureDeferred) isinstance collectionsabc Generatorgetattr __class____name__)values r'&_return_value_looks_like_wrong_libraryzBcoroutine_or_error.._return_value_looks_like_wrong_libraryBsF e[__66 7 54d ; G''+AAAr&triozLTrio was expecting an async function, but instead it got a coroutine object z/ Probably you did something like: trio.run(z4(...)) # incorrect! nursery.start_soon(zO(...)) # incorrect! Instead, you want (notice the parentheses!): trio.run(z2, ...) # correct! nursery.start_soon(z, ...) # correct!z9Trio was expecting an async function, but instead it got u – are you trying to use a library written for asyncio/twisted/tornado or similar? That won't work without some sort of compatibility shim.zTrio got unexpected zAstart_soon expected an async function but got an async generator zCTrio expected an async function, but {!r} appears to be synchronous __qualname__)r5objectreturnbool) sniffio_loopnamer#r.r/r0 Coroutinecloser4inspect isasyncgenformatr2)async_fnargsr6 prev_loopcoros r'coroutine_or_errorrG>s B$0#4#4f I| $&F&  dKOO55 6 1$ 7&th/KK    d #!H&    &>8!LM  K}  h  9 9 : NN &&.\2'//01((0(9(9':;'//01((0(9(9'::L N   2( ;K,;;    =B& sB88BEE E#c8eZdZdZddZddZ ddZy) ConflictDetectoraDetect when two tasks are about to perform operations that would conflict. Use as a synchronous context manager; if two tasks enter it at the same time then the second one raises an error. You can use it when there are two pieces of code that *would* collide and need a lock if they ever were called at the same time, but that should never happen. We use this in particular for things like, making sure that two different tasks don't call sendall simultaneously on the same stream. c ||_d|_yNF)_msg_held)selfmsgs r'__init__zConflictDetector.__init__s  r&ch|jrtj|jd|_y)NT)rMr7BusyResourceErrorrL)rNs r' __enter__zConflictDetector.__enter__s% ::((3 3DJr&cd|_yrK)rM)rNexc_type exc_value tracebacks r'__exit__zConflictDetector.__exit__s  r&N)rOstrr:None)r:rZ)rUztype[BaseException] | NonerVzBaseException | NonerWzTracebackType | Noner:rZ)r4 __module__r8__doc__rPrSrXr%r&r'rIrIs<  ,((   r&rIcdfd }|S)z@Similar to wraps, but for async wrappers of non-async functions.c|_jd|_djdjdd|_|S)N.z Like :meth:`~z `, but async.)r4r8r[r\)func attr_namecls wrapped_clss r' decoratorzasync_wraps..decoratorsW! "//0)=&{'='=&>a @X@X?YYZ[dZeers  r&)r`rr:rr%)rbrcrards``` r' async_wrapsres r&ctdfd |jD]!\}jdr|#y)Nct| vry jt|t|dd}||jdr|_t |dr(d|j vr||_t |dr||_t|tr3|jjD]\}}dz|z||yyyy)Nr[ztrio.r4r_r8) idaddr2 startswithr[hasattrr4r8r.type__dict__items) qualnamer=objmodra attr_valuefix_one module_nameobjnameseen_idss r'rsz&fixup_module_metadata..fix_ones c7h   RWc<. ?s~~g6(CNsJ'Cs||,C# 3/'/C$#t$-0\\-?-?-AN)IzGcMI5y*MN% 7?r&_)rorYr=rYrpr9r:rZ)setrnrj)rt namespacerprsrurvs` @@@r'fixup_module_metadatarzsNHNN*")+ !!#& GWc *+r&c0eZdZdZ ddZddZddZy) generic_functiona:Decorator that makes a function indexable, to communicate non-inferable generic type parameters to a static type checker. If you write:: @generic_function def open_memory_channel(max_buffer_size: int) -> Tuple[ SendChannel[T], ReceiveChannel[T] ]: ... it is valid at runtime to say ``open_memory_channel[bytes](5)``. This behaves identically to ``open_memory_channel(5)`` at runtime, and currently won't type-check without a mypy plugin or clever stubs, but at least it becomes possible to write those. c*t||||_yN)r_fn)rNfns r'rPzgeneric_function.__init__s tR r&c&|j|i|Sr~)r)rNrDkwargss r'__call__zgeneric_function.__call__stxx(((r&c|Sr~r%)rN subscripts r' __getitem__zgeneric_function.__getitem__s r&N)rzCallable[..., RetT]r:rZ)rDr9rr9r:r)rr9r:r)r4r[r8r\rPrrr%r&r'r|r|s(   )r&r|cLt|jd|jd)z5Raises an exception when a final class is subclassed.r_z does not support subclassingr#r[r8)rbs r'_init_final_clsr s' s~~&a(8(8'99VW XXr&c@tt|_t|S)a8Decorator that enforces a class to be final (i.e., subclass not allowed). If a class uses this metaclass like this:: @final class SomeClass: pass The metaclass will ensure that no subclass can be created. Raises ------ - TypeError if a subclass is created ) classmethodr__init_subclass__ std_final) decorateds r' _final_implrs"#.o">I Y r&)rc,eZdZdZddZdfd ZxZS)NoPublicConstructoraMetaclass that ensures a private constructor. If a class uses this metaclass like this:: @final class SomeClass(metaclass=NoPublicConstructor): pass The metaclass will ensure that no instance can be initialized. This should always be used with @final. If you try to instantiate your class (SomeClass()), a TypeError will be thrown. Use _create() instead in the class's implementation. Raises ------ - TypeError if an instance is created. cLt|jd|jd)Nr_z has no public constructorr)rbrDrs r'rzNoPublicConstructor.__call__Bs,~~a 0 011K L  r&c"t||i|Sr~)superr)rbrDrr3s r'_createzNoPublicConstructor._createGsw000r&)rDr9rr9r:rZ)rbtype[T]rDr9rr9r:r)r4r[r8r\rr __classcell__)r3s@r'rr-s& 11r&rc4t|ds t|S |jjd} |j}|d|S#tt f$rd|j jd}Y?wxYw#t$r|j j}YWwxYw)z{Return the fully-qualified name of the async generator function that produced the async generator iterator *agen*. ag_coder4<>r_) rkreprag_frame f_globalsAttributeErrorKeyErrorr co_filenamer8co_name)agenmoduleros r' name_asyncgenrKs 4 #Dz1((4($$XQxj !! H %1T\\--.a01 (<<''(s"A A5)A21A25BBFncyr~r%)wrappedassignedupdateds r'wrapsr`s!r&)rc@d}|j} |#||_~~wxYw)zIThis helper allows re-raising an exception without __context__ being set.T) __context__)exc__tracebackhide__contexts r'raise_saving_contextrjs+ooG ! s ceZdZdZy)MultipleExceptionErrorzbRaised by raise_single_exception_from_group if encountering multiple non-cancelled exceptions.N)r4r[r8r\r%r&r'rrws!r&rc6|jD]$}t|ttfst ||d}d}|jD]2}t|t j r| |}#||}(td|| t||Jdt|y)aThis function takes an exception group that is assumed to have at most one non-cancelled exception, which it reraises as a standalone exception. This exception may be an exceptiongroup itself, in which case it will not be unwrapped. If a :exc:`KeyboardInterrupt` is encountered, a new KeyboardInterrupt is immediately raised with the entire group as cause. If the group only contains :exc:`Cancelled` it reraises the first one encountered. It will retain context and cause of the contained exception, and entirely discard the cause/context of the group(s). If multiple non-cancelled exceptions are encountered, it raises :exc:`AssertionError`. NzwAttempted to unwrap exceptiongroup with multiple non-cancelled exceptions. This is often caused by a bug in the caller.zgroup can't be empty) exceptionsr.KeyboardInterrupt SystemExitrlr7 Cancelledrr)egecancelled_exceptionnoncancelled_exceptions r'!raise_single_exception_from_groupr|s(]]" a+Z8 9q'r !"2637 ]]  a ("*&'# # +%& "(J  )34  *B,BB,-r&)r:r;)rCz-Callable[[Unpack[PosArgsT]], Awaitable[RetT]]rDzUnpack[PosArgsT]r:z1collections.abc.Coroutine[object, NoReturn, RetT])rb type[object]rcrrarYr:zCallable[[CallT], CallT])rtrYryz$collections.abc.Mapping[str, object]r:rZ)rbrr:r )rrr:r)rz$AsyncGeneratorType[object, NoReturn]r:rY)..)rzCallable[..., object]r Sequence[str]rrr:zCallable[[Fn], Fn])r BaseExceptionr:r )rz!BaseExceptionGroup[BaseException]r:r ); __future__rcollections.abcr/r@r r0rrrr functoolsrtypingr r r r r rrsniffiorr<r7rrrsystypesrrtyping_extensionsrrrr version_infoexceptiongrouprrrr(rGrIrerzr|rrrrr9rrr Exceptionrrr%r&r'rs" 99$1  xS12 CLv7GG '!5 g EJ'HV;V V7VrB  $++3+ +Fwt}>Y  , E1'11:"$ Xc6k2 3B#&!$!&!!!  !  !Y! *.)*. *.r&