+ hj#^RIHt^RIt^RIHt^RIt^RIt^RIHt^RIHt^RIH t ^RIH t ^RIH t ^R IH t ^R IH t ^R IHt^R IHt^R IHt^RIHt^RIHt^RIHt^RIHt^RIHt] !R4t]P'd!RR]4tRRltM ^RIHt^RIHt]!]!4R4tRRlt!RR]4t ] !RR R!7t!] 'dR"R#lt"M ]PDt"R$R%lt#R&R'lt$R(R)lt%R*R+lt&R,R-/R.R/llt'!R0R14t(R2R3lt)] 'g]'d]PTt+R#!R4R54t+R#)6) annotationsN)Context)Any) Awaitable)Callable) Coroutine)Optional) TYPE_CHECKING)TypeVar)Union)memoized_property)exc)py311)Literal)Protocol)Self) TypeGuard_TcP]tRt^$t$R]R&R]R&RRltRRltR R ltR tR #) greenletbooldeadzOptional[Context] gr_contextc V^8dQhRRRR/#fnzCallable[..., Any]driverr)formats"\/var/www/html/bestweb/venv/lib/python3.14/site-packages/sqlalchemy/util/_concurrency_py3k.py __annotate__greenlet.__annotate__(sII1I8Ic R#Nrselfrrs&&&r!__init__greenlet.__init__(scr$c V^8dQhRRRR/#)rargrreturnr)r s"r!r"r#*s  c c r$c R#r&r)r(r,s&*r!throwgreenlet.throw*r$c V^8dQhRRRR/#)rvaluerr-r)r s"r!r"r#-s    r$c R#r&r)r(r3s&&r!switchgreenlet.switch-r1r$rN) __name__ __module__ __qualname____firstlineno____annotations__r)r/r5__static_attributes__rr$r!rr$s %%I   r$rcV^8dQhRR/#)rr-rr)r s"r!r"r"0s %%%r$cR#r&rrr$r! getcurrentr?0s#r$)r?)rrc V^8dQhRRRR/#)re BaseExceptionr-rr)r s"r!r"r"=s4r$c\V\4'*;'g+\V\P\P34#r&) isinstance Exceptionasyncio TimeoutErrorCancelledError)rAs&r!is_exit_exceptionrI=s=!Y' '  : G '"8"8 9,r$c2]tRt^Jt$R]R&RtRRltRtR#)_AsyncIoGreenletrrTc V^8dQhRRRR/#rr)r s"r!r"_AsyncIoGreenlet.__annotate__Os00-0x0r$c r\P!WV4\'dVPVnR#R#r&)rr)_has_gr_contextrr's&&&r!r)_AsyncIoGreenlet.__init__Os)$F+ ?$//DO r$)rN)r7r8r9r:r; __sqlalchemy_greenlet_provider__r)r<rr$r!rKrKJs J'+$00r$rK_T_coT) covariantc V^8dQhRRRR/#)r awaitablezAwaitable[_T_co]r-z%TypeGuard[Coroutine[Any, Any, _T_co]]r)r s"r!r"r"Ys44#4 .4r$cR#r&rrUs&r! iscoroutinerXYs03r$c V^8dQhRRRR/#)rrUzAwaitable[Any]r-Noner)r s"r!r"r"asnr$cL\V4'dVP4R#R#r&)rXcloserWs&r!_safe_cancel_awaitabler]as9r$cV^8dQhRR/#rr-rr)r s"r!r"r"hsGGTGr$c0\4p\VRR4#)rQF)r?getattr)currents r! in_greenletrchslG 7> FFr$c V^8dQhRRRR/#rrUz Awaitable[_T]r-rr)r s"r!r"r"ms,,-,B,r$c\4p\VRR4'g"\V4\P!R4hVP P V4#)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. rQFzjgreenlet_spawn has not been called; can't call await_only() here. Was IO attempted in an unexpected place?)r?rar]rMissingGreenletparentr5)rUrbs& r! await_onlyrimsRlG 7> F Fy)!! =   >>  ++r$c V^8dQhRRRR/#rer)r s"r!r"r"s,,m,,r$c\4p\VRR4'gS\4pVP4'd"\ V4\ P !R4hVPV4#VPPV4#)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`. rQFzgreenlet_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?raget_event_loop is_runningr]rrgrun_until_completerhr5)rUrbloops& r!await_fallbackrpsx lG 7> F F ??   "9 -%%;  &&y11 >>  ++r$_require_awaitFc ,V^8dQhRRRRRRRRRR /#) rrzCallable[..., _T]argsrrqrkwargsr-rr)r s"r!r"r"s:,,, ,, ,  ,r$c|"\V\44pRpVP!V/VBpVP'g!RpVGRjxL pVPV4pK2V'dV'g\P!R4hV#L? \d(TP !\ P!4!pKi;i5i)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.) rKr?r5rrBr/sysexc_infor AwaitRequired)rrqrsrtcontextswitch_occurredresultr3s&$*, r!greenlet_spawnr|s"r:<0G O ^^T ,V ,Flll +!LE^^E*Fo G  M! 4]]CLLN3F  4sL:B<B<BBB B<%B<-B<B.B95B<8B99B<cD]tRt^t]RRl4tRRltRRltRtR#) AsyncAdaptedLockcV^8dQhRR/#)rr-z asyncio.Lockr)r s"r!r"AsyncAdaptedLock.__annotate__s|r$c ,\P!4#r&)rFLockr(s&r!mutexAsyncAdaptedLock.mutexs||~r$cV^8dQhRR/#r_r)r s"r!r"rs4444r$c H\VPP44#r&)rpracquirers&r! __enter__AsyncAdaptedLock.__enter__sdjj00233r$c$V^8dQhRRRRRR/#)rr,rkwr-rZr)r s"r!r"rs!Sr$c :VPP4R#r&)rrelease)r(r,rs&*,r!__exit__AsyncAdaptedLock.__exit__s r$rN) r7r8r9r:r rrrr<rr$r!r~r~s# 4 r$r~cV^8dQhRR/#rr-zasyncio.AbstractEventLoopr)r s"r!r"r"s < <1 rs#  *!"# T]  8 &$! *, 50x0 4(4 %%KG ,4,@,!,^   <nnG(6(6r$