+h ddlZddlZddlmZddlmZddlmZddlZddlmZddl m Z dd lm Z e ejd Zd ZGd d ej ZdedefdZdedefdZdddedefdZGddZdZdZdZy)N)Any)Callable) Coroutine)compat)memoized_property)exc gr_contextc|t|t xs*t|tjtjfSN) isinstance Exceptionasyncio TimeoutErrorCancelledError)es T/var/www/html/venv/lib/python3.12/site-packages/sqlalchemy/util/_concurrency_py3k.pyis_exit_exceptionrs8!Y' ' : G '"8"8 9,ceZdZdZy)_AsyncIoGreenletctjj|||||_tr|j|_yyr )greenlet__init__driver_has_gr_contextr )selffnrs rrz_AsyncIoGreenlet.__init__(s6""4V4 $//DO rN)__name__ __module__ __qualname__rrrrr's0rr awaitablereturnctj}t|tst j d|j j|S)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. zjgreenlet_spawn has not been called; can't call await_only() here. Was IO attempted in an unexpected place?)r getcurrentrrr MissingGreenletrswitch)r$currents r await_onlyr+/sL!!#G g/ 0!! =   >>  ++rctj}t|ts@t }|j rt jd|j|S|jj|S)zAwaits 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. zgreenlet_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?) rr'rrget_event_loop is_runningr r(run_until_completerr))r$r*loops rawait_fallbackr1Gso!!#G g/ 0 ?? %%;  &&y11 >>  ++rF)_require_awaitrcKt|tj}d} |j|i|}|js+d} |d{}|j|}|js+|` |r|stjd|S7?#t $r$|j tj}YXwxYw#|` wxYww)aGRuns 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.) rrr'r)dead BaseExceptionthrowsysexc_inforr AwaitRequired)rr2argskwargscontextswitch_occurredresultvalues rgreenlet_spawnr@_sr8#6#6#89G O00,,"O /% !.,, No G  M#%  8' 7  8 NsR!C B<B B  B B<-C B *B96B<8B99B<<CCc(eZdZedZdZdZy)AsyncAdaptedLockc*tjSr )rLockrs rmutexzAsyncAdaptedLock.mutexs||~rcLt|jj|Sr )r1rFacquirerEs r __enter__zAsyncAdaptedLock.__enter__s tzz))+, rc8|jjyr )rFrelease)rargkws r__exit__zAsyncAdaptedLock.__exit__s rN)r r!r"rrFrIrNr#rrrBrBs  rrBczt}|jr td|j||i|S)for test suite/ util onlyz]for async run coroutine we expect that no greenlet or event loop is running when we start out)r-r.rr/rr:r;r0s r"_util_async_run_coroutine_functionrRsE  D  0    " "2t#6v#6 77rct}|js|jt|g|i|St t j tsJ||i|S)rP)r-r.r/r@rrr'rrQs r_util_async_runrTsb  D ?? &&~b'J4'J6'JKK(--/1ABBB4"6""rctjr tjStj S#t$r%tj j cYSwxYw)z}vendor asyncio.get_event_loop() for python 3.7 and above. Python 3.10 deprecates get_event_loop() as a standalone. )rpy37rget_running_loop RuntimeErrorget_event_loop_policyr-r#rrr-r-s\ {{ D++- -%%'' D002AAC C Ds:+A('A()rr7typingrrrrr langhelpersrr hasattrr'rrrr+r1r@rBrRrTr-r#rrr^s * -(--/>0x((0,),,0,i,C,2).+++\" 8 # (r