1P@i! ddlmZddlZddlmZddlZddlZddlmZddlmZddlm Z ddlm Z ddlm Z dd lm Z dd lm Z d d lmZd dlmZd dlmZd dlmZe dZejrGddeZd+dZn ddlmZddlmZeedZd,dZGddeZe ddZe r d-dZn ej:Zd.dZd/d Zd0d!Z d0d"Z!d#d$ d1d%Z"Gd&d'Z# d2d(Z$ d2d)Z%d3d*Z&y)4) annotationsN)Context)Any) Awaitable)Callable) Coroutine)Optional) TYPE_CHECKING)TypeVar)memoized_property)exc)Protocol) TypeGuard_Tc:eZdZUded<ded<d dZd dZd dZy) greenletbooldeadzOptional[Context] gr_contextcyNselffndrivers k/home/www/lebenam.kofcorporation.com/venv/lib/python3.12/site-packages/sqlalchemy/util/_concurrency_py3k.py__init__zgreenlet.__init__$s cyrr)rargs rthrowzgreenlet.throw'r!cyrr)rvalues rswitchzgreenlet.switch*r%r!NrzCallable[..., Any]rr)r#rreturnr)r'rr*r)__name__ __module__ __qualname____annotations__r r$r(rr!rrr s %%   r!rcyrrrr!r getcurrentr0-s r!)r0)rrc|t|t xs*t|tjtjfSr) isinstance Exceptionasyncio TimeoutErrorCancelledError)es ris_exit_exceptionr8;s8!Y' ' : G '"8"8 9,r!c eZdZUded<ddZy)_AsyncIoGreenletrrcptj|||||_tr|j|_yyr)rr r_has_gr_contextrrs rr z_AsyncIoGreenlet.__init__Ks0$F+ $//DO r!Nr))r+r,r-r.r rr!rr:r:Hs J0r!r:_T_coT) covariantcyrr awaitables r iscoroutinerBVs r!c<t|r|jyyr)rBcloser@s r_safe_cancel_awaitablerE_s9r!c6t}t|tSr)r0r2r:)currents r in_greenletrHfslG g/ 00r!ct}t|ts t|t 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?)r0r2r:rErMissingGreenletrr()rArGs r await_onlyrKksMlG g/ 0y)!! =   >>  ++r!ct}t|tsKt}|j r t |t jd|j|S|jj|S)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`. 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?) r0r2r:get_event_loop is_runningrErrJrun_until_completerr()rArGloops rawait_fallbackrQsp lG g/ 0 ??  "9 -%%;  &&y11 >>  ++r!F)_require_awaitcvKt|t}d} |j|i|}|js+d} |d{}|j|}|js+|`|r|stjd|S7?#t$r$|j t j}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.) r:r0r(r BaseExceptionr$sysexc_inforr AwaitRequired)rrRargskwargscontextswitch_occurredresultr's rgreenlet_spawnr]s"r:<0G O00,,"O /% !.,, No G  M#%  8' 7  8 NsQB9 B2BBBB2#B9B*B/,B2.B//B22B66B9c.eZdZeddZddZddZy)AsyncAdaptedLockc*tjSr)r4Lockrs rmutexzAsyncAdaptedLock.mutexs||~r!cHt|jjSr)rQrcacquirerbs r __enter__zAsyncAdaptedLock.__enter__sdjj00233r!c8|jjyr)rcrelease)rr#kws r__exit__zAsyncAdaptedLock.__exit__s r!N)r*z asyncio.Lockr*r)r#rrirr*None)r+r,r-r rcrfrjrr!rr_r_s 4 r!r_czt}|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)rMrNr3rOrrXrYrPs r"_util_async_run_coroutine_functionrpsE  D  0    " "2t#6v#6 77r!ct}|js|jt|g|i|St t t sJ||i|S)rn)rMrNrOr]r2r0r:ros r_util_async_runrrs[  D ?? &&~b'J4'J6'JKK*,(89994"6""r!c tjS#t$rYnwxYwtjj S)z}vendor asyncio.get_event_loop() for python 3.7 and above. Python 3.10 deprecates get_event_loop() as a standalone. )r4get_running_loop RuntimeErrorget_event_loop_policyrMrr!rrMrMsB  ''))      ( ( * 9 9 ;;s  "")r*r)r7rTr*r)rAzAwaitable[_T_co]r*z%TypeGuard[Coroutine[Any, Any, _T_co]])rAzAwaitable[Any]r*rlrk)rAz Awaitable[_T]r*r) rzCallable[..., _T]rXrrRrrYrr*r)rz'Callable[..., Coroutine[Any, Any, Any]]rXrrYrr*r)r*zasyncio.AbstractEventLoop)' __future__rr4 contextvarsrrUtypingrrrrr r r langhelpersr r util.typingrrrrr0hasattrr<r8r:r=rBrErHrKrQr]r_rprrrMrr!rr~s]#  *"# T]  8  $! *, 50x0 4( # . %%K1 ,4,F!// // /  /d   8/ 88; 8GJ 8 8 #/ #8; #GJ # #