o "i~!@sddlmZddlZddlmZddlZddlZddlmZddlmZddlm Z ddlm Z ddlm Z dd lm Z dd lm Z d d lmZd dlmZd dlmZd dlmZe dZej roGdddeZdHddZn ddlmZddlmZeedZdIddZGdd d eZe d!d"d#Ze rdJd'd(ZnejZdKd+d,ZdLd-d.ZdMd0d1Z dMd2d3Z!d4d5dNdd?d?Z#dOdAdBZ$dOdCdDZ%dPdFdGZ&dS)Q) annotationsN)Context)Any) Awaitable)Callable) Coroutine)Optional) TYPE_CHECKING)TypeVar)memoized_property)exc)Protocol) TypeGuard_Tc@s<eZdZUded<ded<ddd Zdd dZdddZdS)greenletbooldeadzOptional[Context] gr_contextfnCallable[..., Any]drivercCdSNselfrrrre/var/www/html/voicebot/backend/venv/lib/python3.10/site-packages/sqlalchemy/util/_concurrency_py3k.py__init__$zgreenlet.__init__argrreturncGrrr)rr!rrrthrow&zgreenlet.throwvaluecCrrr)rr%rrrswitch)r$zgreenlet.switchNrrrr)r!rr"r)r%rr"r)__name__ __module__ __qualname____annotations__rr#r&rrrrr s   rr"cCrrrrrrr getcurrent,r r,)r,)rre BaseExceptionrcCst|t pt|tjtjfSr) isinstance Exceptionasyncio TimeoutErrorCancelledError)r-rrris_exit_exception9s r4c@s eZdZUded<d ddZd S) _AsyncIoGreenletrrrrrrcCs(t|||||_tr|j|_dSdSr)rrr_has_gr_contextrrrrrrIs  z_AsyncIoGreenlet.__init__Nr')r(r)r*r+rrrrrr5Fs r5_T_coT) covariant awaitableAwaitable[_T_co]%TypeGuard[Coroutine[Any, Any, _T_co]]cCrrrr9rrr iscoroutineTsr=Awaitable[Any]NonecCst|r |dSdSr)r=closer<rrr_safe_cancel_awaitable\s rAcCst}t|tSr)r,r/r5)currentrrr in_greenletcs rC Awaitable[_T]cCs.t}t|tst|td|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,r/r5rArMissingGreenletrr&)r9rBrrr await_onlyhs  rFcCsFt}t|tst}|rt|td||S|j |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?) r,r/r5get_event_loop is_runningrArrErun_until_completerr&)r9rBlooprrrawait_fallbacks   rKF)_require_awaitrCallable[..., _T]argsrrLkwargscst|t}d}z1|j|i|}|js7d}z|IdH}Wnty.|jt}Ynw||}|jrW|`n|`w|rG|sGt d|S)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.) r5r,r&rr.r#sysexc_inforr AwaitRequired)rrLrNrOcontextswitch_occurredresultr%rrrgreenlet_spawns*    rVc@s.eZdZedddZdddZdd d ZdS)AsyncAdaptedLockr" asyncio.LockcCstSr)r1LockrrrrmutexszAsyncAdaptedLock.mutexrcCst|jSr)rKr[acquirerZrrr __enter__szAsyncAdaptedLock.__enter__r!rkwr?cOs|jdSr)r[release)rr!r^rrr__exit__szAsyncAdaptedLock.__exit__N)r"rXr"r)r!rr^rr"r?)r(r)r*r r[r]r`rrrrrWs   rW'Callable[..., Coroutine[Any, Any, Any]]cOs*t}|r td|||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)rGrHr0rIrrNrOrJrrr"_util_async_run_coroutine_functions recOsHt}|s|t|g|Ri|StttsJ||i|S)rc)rGrHrIrVr/r,r5rdrrr_util_async_runs rfasyncio.AbstractEventLoopcCs*ztWStyYnwtS)z}vendor asyncio.get_event_loop() for python 3.7 and above. Python 3.10 deprecates get_event_loop() as a standalone. )r1get_running_loop RuntimeErrorget_event_loop_policyrGrrrrrGs    rG)r"r)r-r.r"r)r9r:r"r;)r9r>r"r?ra)r9rDr"r) rrMrNrrLrrOrr"r)rrbrNrrOrr"r)r"rg)' __future__rr1 contextvarsrrPtypingrrrrrr r langhelpersr r util.typingrrrrr,hasattrr6r4r5r7r=rArCrFrKrVrWrerfrGrrrrsN                       #2