]j#SSKJr SSKrSSKJr SSKrSSKrSSKJr SSKJr SSKJ r SSKJ r SSKJ r SS KJ r SS KJ r SS KJr S S KJr SSKJr SSKJr SSKJr SSKJr SSKJr SSKJr \ "S5r\R(a"SS\5rS/SjrO SSKJr SSKJr \"\"5S5rS0Sjr"SS\5r \ "SS S!9r!\ (a S1S"jr"O \RDr"S2S#jr#S3S$jr$S4S%jr%S4S&jr&S'S(.S5S)jjr'"S*S+5r(S6S,jr)\ (d\(a \RTr+g"S-S.5r+g)7) annotationsN)Context)Any) Awaitable)Callable) Coroutine)Optional) TYPE_CHECKING)TypeVar)Union)memoized_property)exc)py311)Literal)Protocol)Self) TypeGuard_TcH\rSrSr%S\S'S\S'S SjrS SjrS SjrS rg )greenlet$booldeadzOptional[Context] gr_contextcgNselffndrivers ^/home/mande/repo/quber/.venv/lib/python3.13/site-packages/sqlalchemy/util/_concurrency_py3k.py__init__greenlet.__init__(sccgrr)r!args r$throwgreenlet.throw*r'cgrr)r!values r$switchgreenlet.switch-r,r'rNr"zCallable[..., Any]r#r)r)rreturnr)r.rr2r) __name__ __module__ __qualname____firstlineno____annotations__r%r*r/__static_attributes__rr'r$rr$s %%I  r'rcgrrrr'r$ getcurrentr:0s#r')r:)rrc[U[5(+=(d* [U[R[R45$r) isinstance Exceptionasyncio TimeoutErrorCancelledError)es r$is_exit_exceptionrB=s8!Y' ' : G '"8"8 9,r'c.\rSrSr%S\S'SrSSjrSrg) _AsyncIoGreenletJrrTcl[R"XU5 [(aURUlggr)rr%_has_gr_contextrr s r$r%_AsyncIoGreenlet.__init__Os)$F+ ?$//DO r')rNr1)r3r4r5r6r7 __sqlalchemy_greenlet_provider__r%r8rr'r$rDrDJs J'+$0r'rD_T_coT) covariantcgrr awaitables r$ iscoroutinerOYs03r'cF[U5(aUR5 ggr)rOcloserMs r$_safe_cancel_awaitablerRas9r'c0[5n[USS5$)NrIF)r:getattr)currents r$ in_greenletrVhslG 7> FFr'c[5n[USS5(d![U5 [R"S5eUR R U5$)zAwaits an async function in a sync method. The sync method must be inside a :func:`greenlet_spawn` context. :func:`await_only` calls cannot be nested. :param awaitable: The coroutine to call. rIFzjgreenlet_spawn has not been called; can't call await_only() here. Was IO attempted in an unexpected place?)r:rTrRrMissingGreenletparentr/)rNrUs r$ await_onlyrZmsRlG 7> F Fy)!! =   >>  ++r'c[5n[USS5(dQ[5nUR5(a![ U5 [ R "S5eURU5$URRU5$)aAwaits an async function in a sync method. The sync method must be inside a :func:`greenlet_spawn` context. :func:`await_fallback` calls cannot be nested. :param awaitable: The coroutine to call. .. deprecated:: 2.0.24 The ``await_fallback()`` function will be removed in SQLAlchemy 2.1. Use :func:`_util.await_only` instead, running the function / program / etc. within a top-level greenlet that is set up using :func:`_util.greenlet_spawn`. rIFzgreenlet_spawn has not been called and asyncio event loop is already running; can't call await_fallback() here. Was IO attempted in an unexpected place?) r:rTget_event_loop is_runningrRrrXrun_until_completerYr/)rNrUloops r$await_fallbackr`sx lG 7> F F ??   "9 -%%;  &&y11 >>  ++r'F)_require_awaitc# [U[55nSnUR"U0UD6nUR(d1SnUIShvN nURU5nUR(dM1U(aU(d[R"S5eU$NN![a% UR "[ R"56nNif=f7f)a/Runs a sync function ``fn`` in a new greenlet. The sync function can then use :func:`await_only` to wait for async functions. :param fn: The sync callable to call. :param \*args: Positional arguments to pass to the ``fn`` callable. :param \*\*kwargs: Keyword arguments to pass to the ``fn`` callable. FTNzThe current operation required an async execution but none was detected. This will usually happen when using a non compatible DBAPI driver. Please ensure that an async DBAPI is used.) rDr:r/r BaseExceptionr*sysexc_infor AwaitRequired)r"raargskwargscontextswitch_occurredresultr.s r$greenlet_spawnrls"r:<0G O ^^T ,V ,Fll +!LE^^E*Flllo G  M! 4]]CLLN3F  4s@Lockr!s r$mutexAsyncAdaptedLock.mutexs||~r'cH[URR55$r)r`rsacquirerrs r$ __enter__AsyncAdaptedLock.__enter__sdjj00233r'c8URR5 gr)rsrelease)r!r)kws r$__exit__AsyncAdaptedLock.__exit__s r'rN)r2z asyncio.Lockr2r)r)rr{rr2None) r3r4r5r6rrsrwr|r8rr'r$rnrns 4 r'rnc[R"5$![a Of=f[R"5R 5$)zuvendor asyncio.get_event_loop() for python 3.7 and above. Python 3.10 deprecates get_event_loop() as a standalone. )r>get_running_loop RuntimeErrorget_event_loop_policyr\rr'r$r\r\sB  ''))      ( ( * 9 9 ;;s  $$cj\rSrSr%SrS\S'SSjrSSjrSSjrSSjr SS jr SS jr SS jr S r g )_Runnerz#Runner implementation for test onlyz6Union[None, asyncio.AbstractEventLoop, Literal[False]]_loopcSUlgrrrrs r$r%_Runner.__init__s DJr'c&UR5 U$r) _lazy_initrrs r$rw_Runner.__enter__s OO Kr'c$UR5 gr)rQ)r!exc_typeexc_valexc_tbs r$r|_Runner.__exit__s JJLr'cUR(aVURRURR55 URR5 SUlgg!URR5 SUlf=f)NF)rr^shutdown_asyncgensrQrrs r$rQ _Runner.closesizz'JJ11 557JJ$$&!&DJ JJ$$&!&DJs 3A))#B c`UR5 UR(deUR$)zReturn embedded event loop.)rrrrs r$get_loop_Runner.get_loops" OO :: ::: r'c~UR5 UR(deURRU5$r)rrr^)r!coros r$run _Runner.runs- OO :: :::006 6r'cURSLa [S5eURc[R"5Ulgg)NFzRunner is closed)rrr>new_event_looprrs r$r_Runner._lazy_inits9zzU""#566zz!$335 "r'rN)r2r)r2r)rrrrrrr2rr2zasyncio.AbstractEventLoop)rzCoroutine[Any, Any, _T]r2r)r3r4r5r6__doc__r7r%rwr|rQrrrr8rr'r$rrs.1EE    '   7  6r'r)r2r)rArcr2r)rNzAwaitable[_T_co]r2z%TypeGuard[Coroutine[Any, Any, _T_co]])rNzAwaitable[Any]r2rr~)rNz Awaitable[_T]r2r) r"zCallable[..., _T]rgrrarrhrr2rr), __future__rr> contextvarsrrdtypingrrrrr r r r langhelpersrrutilr util.typingrrrrrrr:hasattrrGrBrDrJrOrRrVrZr`rlrnr\Runnerrrr'r$rs:#  *!"# T]  8 &$! *, 50x0 4(4#4 .4 %%KG ,4,F!,, ,, ,  ,^   <nnG(6(6r'