o =a @s"ddlZddlZddlmZddlmZddlmZddlZddlmZddl m Z dd lm Z ej rOzdd l mZeejd WneefyNdZYnwdZd d ZGdddejZdedefddZdedefddZdddedefddZGdddZddZdd Zd!d"ZdS)#N)Any)Callable) Coroutine)compat)memoized_property)exc) copy_context gr_contextcCst|t pt|tjtjfSN) isinstance Exceptionasyncio TimeoutErrorCancelledError)erW/var/www/html/gps/gps/lib/python3.10/site-packages/sqlalchemy/util/_concurrency_py3k.pyis_exit_exceptions rc@seZdZddZdS)_AsyncIoGreenletcCs.tj|||||_tdurt|_dSdSr )greenlet__init__driver _copy_contextr )selffnrrrrr)s  z_AsyncIoGreenlet.__init__N)__name__ __module__ __qualname__rrrrrr(s r awaitablereturncCs(t}t|tstd|j|S)Awaits an async function in a sync method. The sync method must be inside a :func:`greenlet_spawn` context. :func:`await_` calls cannot be nested. :param awaitable: The coroutine to call. zfgreenlet_spawn has not been called; can't call await_() here. Was IO attempted in an unexpected place?)r getcurrentr rr MissingGreenletrswitch)r currentrrr await_only0s   r'cCs@t}t|tst}|rtd||S|j |S)r"zgreenlet_spawn has not been called and asyncio event loop is already running; can't call await_() here. Was IO attempted in an unexpected place?) rr#r rget_event_loop is_runningr r$run_until_completerr%)r r&looprrrawait_fallbackHs   r,F)_require_awaitrcst|t}d}z1|j|i|}|js8d}z|IdH}Wnty/|jt}Ynw||}|jrW|` n|` w|rH|sHt d|S)aCRuns a sync function ``fn`` in a new greenlet. The sync function can then use :func:`await_` 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)rr-argskwargscontextswitch_occurredresultvaluerrrgreenlet_spawn`s*    r:c@s(eZdZeddZddZddZdS)AsyncAdaptedLockcCstSr )rLockrrrrmutexszAsyncAdaptedLock.mutexcCst|j|Sr )r,r>acquirer=rrr __enter__szAsyncAdaptedLock.__enter__cOs|jdSr )r>release)rargkwrrr__exit__szAsyncAdaptedLock.__exit__N)rrrrr>r@rDrrrrr;s   r;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)r(r)rr*rr4r5r+rrr"_util_async_run_coroutine_functions rGcOsJt}|s|t|g|Ri|StttsJ||i|S)rE)r(r)r*r:r rr#rrFrrr_util_async_runs rHcCs8tjrztWStytYSwtS)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(rrrrr(s  r()rr1typingrrrrr langhelpersrr rI contextvarsr rgetattr ImportErrorAttributeErrorrrr'r,r:r;rGrHr(rrrrs>         .