i#RddlmZddlZddlmZddlZddlZddlmZddlmZddlm Z ddlm Z ddlm Z dd lm Z dd lm Z dd lmZd d lmZddlmZddlmZddlmZddlmZddlmZddlmZe dZej rGddeZd@dZn ddlmZddlmZeedZdAd ZGd!d"eZ e d#d$%Z!e rdBd)Z"nej"Z"dCd,Z#dDd-Z$dEd/Z%dEd0Z&d1d2dFd9Z'Gd:d;Z(dGd=Z)e s er ej*Z+dSGd>d?Z+dS)H) annotationsN)Context)Any) Awaitable)Callable) Coroutine)Optional) TYPE_CHECKING)TypeVar)Union)memoized_property)exc)py311)Literal)Protocol)Self) TypeGuard_Tc<eZdZUded<ded<ddZdd ZddZdS)greenletbooldeadzOptional[Context] gr_contextfnCallable[..., Any]drivercdSNselfrrs g/var/www/html/crypto-bot/backend/venv/lib/python3.11/site-packages/sqlalchemy/util/_concurrency_py3k.py__init__zgreenlet.__init__(argrreturncdSr r!)r#r(s r$throwzgreenlet.throw*4r'valuecdSr r!)r#r-s r$switchzgreenlet.switch-r,r'Nrrrr)r(rr)r)r-rr)r)__name__ __module__ __qualname____annotations__r%r+r/r!r'r$rr$s_ %%%%IIII          r'rr)cdSr r!r!r'r$ getcurrentr60r&r')r6)rre BaseExceptionrczt|t p%t|tjtjfSr ) isinstance Exceptionasyncio TimeoutErrorCancelledError)r7s r$is_exit_exceptionr?=s:!Y'' ' : G '"8 9,,r'c"eZdZUded<d dZdS) _AsyncIoGreenletrrrrrrcjtj|||||_tr|j|_dSdSr )rr%r_has_gr_contextrr"s r$r%z_AsyncIoGreenlet.__init__Ms>$F+++  0$/DOOO 0 0r'Nr0)r1r2r3r4r%r!r'r$rArAJs3JJJ000000r'rA_T_coT) covariant awaitableAwaitable[_T_co]%TypeGuard[Coroutine[Any, Any, _T_co]]cdSr r!rFs r$ iscoroutinerKXs03r'Awaitable[Any]NonecPt|r|dSdSr )rKcloserJs r$_safe_cancel_awaitablerP`s49r'cHt}t|tSr )r6r:rA)currents r$ in_greenletrSgsllG g/ 0 00r' Awaitable[_T]ct}t|ts#t|t jd|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?)r6r:rArPrMissingGreenletrr/)rFrRs r$ await_onlyrWls`llG g/ 0 0 y)))! =    >  + ++r'c0t}t|tsZt}|r#t |t jd||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?) r6r:rAget_event_loop is_runningrPrrVrun_until_completerr/)rFrRloops r$await_fallbackr]s llG g/ 0 0 2 ??    "9 - - -%;  &&y111 >  + ++r'F)_require_awaitrCallable[..., _T]argsrr^kwargscZKt|t}d} |j|i|}|jsSd} |d{V}||}n+#t$r|jt j}YnwxYw|jS|`n#|`wxYw|r|stj 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.) rAr6r/rr8r+sysexc_inforr AwaitRequired)rr^r`racontextswitch_occurredresultr-s r$greenlet_spawnris"r:<<00G O000, /"O /% !.. ! 8 8 8' 7  8 , / NNGN o  G   Ms.B AB %A?<B >A?? B Bc6eZdZed dZd dZdd Zd S)AsyncAdaptedLockr) asyncio.Lockc(tjSr )r<Lockr#s r$mutexzAsyncAdaptedLock.mutexs|~~r'rcNt|jSr )r]rpacquireros r$ __enter__zAsyncAdaptedLock.__enter__s dj0022333r'r(rkwrMc8|jdSr )rprelease)r#r(rts r$__exit__zAsyncAdaptedLock.__exit__s r'N)r)rlr)r)r(rrtrr)rM)r1r2r3rrprsrwr!r'r$rkrks[ 4444 r'rkasyncio.AbstractEventLoopc tjS#t$rYnwxYwtjS)z}vendor asyncio.get_event_loop() for python 3.7 and above. Python 3.10 deprecates get_event_loop() as a standalone. )r<get_running_loop RuntimeErrorget_event_loop_policyrYr!r'r$rYrYsS  ')))        ( * * 9 9 ; ;;s  ""cVeZdZUdZded<ddZddZdd ZddZddZ ddZ ddZ dS)_Runnerz#Runner implementation for test onlyz6Union[None, asyncio.AbstractEventLoop, Literal[False]]_loopr)rMcd|_dSr )rros r$r%z_Runner.__init__s DJJJr'rc.||Sr ) _lazy_initros r$rsz_Runner.__enter__s OO   Kr'exc_typerexc_valexc_tbc.|dSr )rO)r#rrrs r$rwz_Runner.__exit__s JJLLLLLr'c|jry |j|j|jd|_dS#|jd|_wxYwdS)NF)rr[shutdown_asyncgensrOros r$rOz _Runner.close sz ''J11 5577J$$&&&!&DJJJJ$$&&&!&DJ&&&& ' 's 1A"A>rycJ||jsJ|jS)zReturn embedded event loop.)rrros r$get_loopz_Runner.get_loops' OO   :  :: r'coroCoroutine[Any, Any, _T]rcp||jsJ|j|Sr )rrr[)r#rs r$runz _Runner.runs5 OO   :  ::0066 6r'cx|jdurtd|jtj|_dSdS)NFzRunner is closed)rr|r<new_event_loopros r$rz_Runner._lazy_initsBzU"""#5666z!$355 "!r'N)r)rM)r)r)rrrrrrr)rMr)ry)rrr)r) r1r2r3__doc__r4r%rsrwrOrrrr!r'r$rrs11EEEE             ' ' ' '      7 7 7 7  6 6 6 6 6 6r'r)r)r)r7r8r)r)rFrGr)rH)rFrLr)rMrx)rFrTr)r) rr_r`rr^rrarr)rr), __future__rr< contextvarsrrctypingrrrrr r r r langhelpersrrutilr util.typingrrrrrrr6hasattrrCr?rArDrKrPrSrWr]rirkrYRunnerrr!r'r$rsd#"""""  ******!!!!!!""""""###### WT]] "     8   &%%%%$#####!!!!!! '**,, 5500000x000 4(((&44444 %K1111 ,,,,4,,,,F!//////d         < < < <,6,6nGGG(6(6(6(6(6(6(6(6(6(6r'