o Rc@sddlZddlZddlmZddlmZddlmZddlZddlmZddl m Z dd lm Z e e d Zd d ZGd ddejZdedefddZdedefddZdddedefddZGdddZddZddZd d!ZdS)"N)Any)Callable) Coroutine)compat)memoized_property)exc gr_contextcCst|t pt|tjtjfSN) isinstance Exceptionasyncio TimeoutErrorCancelledError)erCD:\Flask\env\Lib\site-packages\sqlalchemy/util/_concurrency_py3k.pyis_exit_exceptions rc@seZdZddZdS)_AsyncIoGreenletcCs*tj|||||_tr|j|_dSdSr )greenlet__init__driver_has_gr_contextr )selffnrrrrr(s  z_AsyncIoGreenlet.__init__N)__name__ __module__ __qualname__rrrrrr's r awaitablereturncCs(t}t|tstd|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 getcurrentr rr MissingGreenletrswitch)rcurrentrrr await_only/s   r%cCs@t}t|tst}|rtd||S|j |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!r rget_event_loop is_runningr r"run_until_completerr#)rr$looprrrawait_fallbackGs   r*F)_require_awaitrcst|t}d}z1|j|i|}|js8d}z|IdH}Wnty/|jt}Ynw||}|jrW|` n|` w|rH|sHt 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.) rrr!r#Zdead BaseExceptionthrowsysexc_inforr Z AwaitRequired)rr+argskwargscontextZswitch_occurredresultvaluerrrgreenlet_spawn_s*    r5c@s(eZdZeddZddZddZdS)AsyncAdaptedLockcCstSr )rLockrrrrmutexszAsyncAdaptedLock.mutexcCst|j|Sr )r*r9acquirer8rrr __enter__szAsyncAdaptedLock.__enter__cOs|jdSr )r9release)rargkwrrr__exit__szAsyncAdaptedLock.__exit__N)rrrrr9r;r?rrrrr6s   r6cOs*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'r r(rr0r1r)rrr"_util_async_run_coroutine_functions rBcOsJt}|s|t|g|Ri|StttsJ||i|S)r@)r&r'r(r5r rr!rrArrr_util_async_runs rCcCs8tjrztWStytYSwtS)z}vendor asyncio.get_event_loop() for python 3.7 and above. Python 3.10 deprecates get_event_loop() as a standalone. )rZpy37rget_running_loop RuntimeErrorget_event_loop_policyr&rrrrr&s  r&)rr.typingrrrrrZ langhelpersrr hasattrr!rrrr%r*r5r6rBrCr&rrrrs0        .