vKg8SSKJr SSKrSSKrSSKrSSKrSSKrSSKJ r SSK J r SSK J r JrJrJrJrJrJrJrJr SSKJr SSKr\"S\S\4S 9r\"S 5r\"S 5r\ (a$SS KJrJ r SS K!J"r"J#r#J$r$J%r% \""S5r&\$"S5r'\ (aS'Sjr(OV\RRS:XaASSK*r*\*RV"5r,\,R[S5 \,R]S5r/\0"\/S5r(OS'Sjr(S(Sjr1S)Sjr2"SS5r3S*Sjr4S+Sjr5"SS\\5r6S,Sjr7S-Sjr8\ (aSS K Jr O\8r\"S!S"\ 55r9S.S#jr:\ (a\"S$\S\;4S 9r<S/S0S%jjr=gSS&K J=r= g)1) annotationsN)ABCMeta)update_wrapper) TYPE_CHECKINGAny AwaitableCallableGenericNoReturnSequenceTypeVarfinal) thread_localCallT.)boundTRetT)AsyncGeneratorType TracebackType) ParamSpecSelf TypeVarTupleUnpackArgsTPosArgsTcgNsignums J/var/www/highfloat_scraper/venv/lib/python3.13/site-packages/trio/_util.py signal_raiser"*s3ntzint raise(int);z!api-ms-win-crt-runtime-l1-1-0.dllraisecX[R"[R"5U5 gr)signal pthread_kill threading get_identrs r!r"r"ZsI//16:r#c[R"[R[R"[R55 g![[4a gf=f)z7Attempt to reliably check if we are in the main thread.TF)r'SIGINT getsignal TypeError ValueErrorrr#r!is_main_threadr0fsB fmmV%5%5fmm%DE z "sAA AAc SSjn[RSsn[lU"U6nU[l[U[R R 5(dlU"U5(a[S U<S 35e[R"U5(a[S U<35e[S R[USU555eU$![a [U[R R 5(aUUR5 [SU<SURSURSURSURS3 5SeU"U5(a[S U<S 35Seef=f!U[lf=f)Nc[U[RR5(ag[ USS5bgUR R S;$)NT_asyncio_future_blocking)FutureDeferred) isinstance collectionsabc Generatorgetattr __class____name__)values r!&_return_value_looks_like_wrong_libraryBcoroutine_or_error.._return_value_looks_like_wrong_librarywsI e[__66 7 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__)r=objectreturnbool) sniffio_loopnamer.r6r7r8 Coroutinecloser<inspect isasyncgenformatr:)async_fnargsr> prev_loopcoros r!coroutine_or_errorrPss B$0#4#4f I| $&F&  dKOO55 6 6 1$ 7 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& sC B(E33E66 FcF\rSrSrSrSSjrS SjrS SjrSrg) 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. cXlSUlgNF)_msg_held)selfmsgs r!__init__ConflictDetector.__init__s  r#ctUR(a [R"UR5eSUlg)NT)rWr@BusyResourceErrorrV)rXs r! __enter__ConflictDetector.__enter__s% ::((3 3DJr#cSUlgrU)rW)rXexc_type exc_value tracebacks r!__exit__ConflictDetector.__exit__s  r#)rWrVN)rYstrrCNone)rCrg)raztype[BaseException] | NonerbzBaseException | NonerczTracebackType | NonerCrg) r< __module__rA__firstlineno____doc__rZr^rd__static_attributes__rr#r!rRrRs<  ,((   r#rRc ^^^SUUU4SjjnU$)z@Similar to wraps, but for async wrappers of non-async functions.c>TUlTRST3UlSTRSTRSTS3UlU$)N.z Like :meth:`~z `, but async.)r<rArhrj)func attr_namecls wrapped_clss r! decoratorasync_wraps..decoratorsW! "//0)=&{'='=&>a @X@X?YYZ[dZeers  r#)rorrCrr)rqrrrprss``` r! async_wrapsrus r#c^^^^[5mSUUUU4SjjmUR5H(umnTRS5(aMT"TTU5 M* g)Nc>[U5T ;agT R[U55 [USS5nUbURS5(aTUl[ US5(a-SUR ;aXl[ US5(aXl[U[5(a3URR5HupET"TS-U-XE5 M gggg)Nrhztrio.r<rnrA) idaddr: startswithrhhasattrr<rAr6type__dict__items) qualnamerFobjmodrp attr_valuefix_one module_nameobjnameseen_idss r!r&fixup_module_metadata..fix_ones c7h   RWc<. ?s~~g66(CNsJ''Cs||,C# 3//'/$#t$$-0\\-?-?-A)IGcMI5yM.B% 7?r#_)rrfrFrfrrBrCrg)setr~rz)r namespacerrrrs` @@@r!fixup_module_metadatarsLHNN*") !!#&& GWc **r#c6\rSrSrSrSSjrS SjrS SjrSrg) generic_functioni"aDecorator that makes a function indexable, to communicate non-inferrable 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&[X5 Xlgr)r_fn)rXfns r!rZgeneric_function.__init__3st r#c&UR"U0UD6$rr)rXrMkwargss r!__call__generic_function.__call__7sxx(((r#cU$rr)rX subscripts r! __getitem__generic_function.__getitem__:s r#rN)rzCallable[..., RetT]rCrg)rMrrrrCr)rrBrCr) r<rhrArirjrZrrrkrr#r!rr"s )r#rcL[URSURS35e)z5Raises an exception when a final class is subclassed.rnz does not support subclassingr.rhrA)rqs r!_init_final_clsr>s' s~~&a(8(8'99VW XXr#c@[[5Ul[U5$)aDecorator 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_implrCs"#.o">I Y r#)rc:^\rSrSrSrSSjrSU4SjjrSrU=r$)NoPublicConstructori_aMetaclass 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. cL[URSURS35e)Nrnz has no public constructorr)rqrMrs r!rNoPublicConstructor.__call__ts,~~a 0 011K L  r#c$>[TU]"U0UD6$r)superr)rqrMrr;s r!_createNoPublicConstructor._createysw000r#r)rMrBrrBrCrg)rqtype[T]rMrBrrBrCr) r<rhrArirjrrrk __classcell__)r;s@r!rr_s& 11r#rcB[US5(d [U5$URRSnURnUSU3$![[ 4a SUR RS3nN@f=f![a UR RnNYf=f)zsReturn the fully-qualified name of the async generator function that produced the async generator iterator *agen*. ag_coder<<>rn) r{reprag_frame f_globalsAttributeErrorKeyErrorr co_filenamerAco_name)agenmodulers r! name_asyncgenr}s 4 # #Dz1((4($$XQxj !! H %1T\\--.a01 (<<''(s"A A; *A87A8; BBFncgrr)wrappedassignedupdateds r!wrapsrs!r#)r)r intrCrg)rCrD)rLz-Callable[[Unpack[PosArgsT]], Awaitable[RetT]]rMzUnpack[PosArgsT]rCz1collections.abc.Coroutine[object, NoReturn, RetT])rq type[object]rrrrprfrCzCallable[[CallT], CallT])rrfrz$collections.abc.Mapping[str, object]rCrg)rqrrCr )rrrCr)rz$AsyncGeneratorType[object, NoReturn]rCrf)..)rzCallable[..., object]r Sequence[str]rrrCzCallable[[Fn], Fn])> __future__rcollections.abcr7rIosr'r)r8r functoolsrtypingrrrr r r r r rrsniffiorrEr@rrrtypesrrtyping_extensionsrrrrrrr"rFcffiFFI_fficdefdlopen_libr:r0rPrRrurrrrrrrBrrrr#r!rs" $   1 xS12 CLv7GG g EJ'H.WW_H 88:DII ;;: ;D4)L;V;V V7VrB  $++3+ +Fwt}8Y  , E1'11:"$ Xc6k2 3B#&!$!&!!!  ! r#