V.j$VddlmZddlZddlmZddlZddlZddlmZddlmZddlm Z ddlm Z ddlm Z dd lm Z dd lm Z dd lmZd d lmZddlmZddlmZddlmZddlmZddlmZddlmZe dZejrGddeZd/dZn ddlmZddlmZeedZd0dZGddeZ e dd !Z!e r d1d"Z"n ejDZ"d2d#Z#d3d$Z$d4d%Z%d4d&Z&d'd( d5d)Z'Gd*d+Z(d6d,Z)e ser ejTZ+yGd-d.Z+y)7) annotationsN)Context)Any) Awaitable)Callable) Coroutine)Optional) TYPE_CHECKING)TypeVar)Union)memoized_property)exc)py311)Literal)Protocol)Self) TypeGuard_Tc:eZdZUded<ded<d dZd dZd dZy) greenletbooldeadzOptional[Context] gr_contextcyNselffndrivers cC:\xampp\htdocs\tradingbinance\backend\.venv\Lib\site-packages\sqlalchemy/util/_concurrency_py3k.py__init__zgreenlet.__init__(sccyrr)r args r#throwzgreenlet.throw*r%cyrr)r values r#switchzgreenlet.switch-r)r%Nr!zCallable[..., Any]r"r)r'rreturnr)r+rr.r)__name__ __module__ __qualname____annotations__r$r(r,rr%r#rr$s %%I  r%rcyrrrr%r# getcurrentr40s#r%)r4)rrc|t|t xs*t|tjtjfSr) isinstance Exceptionasyncio TimeoutErrorCancelledError)es r#is_exit_exceptionr<=s8!Y' ' : G '"8"8 9,r%c$eZdZUded<dZddZy)_AsyncIoGreenletrrTcbtj|||tr|j|_yyr)rr$_has_gr_contextrrs r#r$z_AsyncIoGreenlet.__init__Os)$F+ $//DO r%Nr-)r/r0r1r2 __sqlalchemy_greenlet_provider__r$rr%r#r>r>Js J'+$0r%r>_T_coT) covariantcyrr awaitables r# iscoroutinerGYs03r%c<t|r|jyyr)rGcloserEs r#_safe_cancel_awaitablerJas9r%c0t}t|ddS)NrAF)r4getattr)currents r# in_greenletrNhslG 7> FFr%ct}t|dds t|tjd|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. rAFzjgreenlet_spawn has not been called; can't call await_only() here. Was IO attempted in an unexpected place?)r4rLrJrMissingGreenletparentr,)rFrMs r# await_onlyrRmsOlG 7> Fy)!! =   >>  ++r%ct}t|ddsKt}|jr t |t j d|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`. rAFzgreenlet_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?) r4rLget_event_loop is_runningrJrrPrun_until_completerQr,)rFrMloops r#await_fallbackrXsr lG 7> F ??  "9 -%%;  &&y11 >>  ++r%F)_require_awaitcbKt|t}d}|j|i|}|js+d} |d{}|j|}|js+|r|stjd|S7=#t$r$|j t j}YVwxYww)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>r4r,r BaseExceptionr(sysexc_infor AwaitRequired)r!rYargskwargscontextswitch_occurredresultr+s r#greenlet_spawnrds"r:<0G O W^^T ,V ,Fll +!LE^^E*Fllo G  M! 4#W]]CLLN3F  4s?7B/A?A=A?B/"B/=A??*B,)B/+B,,B/c.eZdZeddZddZddZy)AsyncAdaptedLockc*tjSr)r8Lockr s r#mutexzAsyncAdaptedLock.mutexs||~r%cHt|jjSr)rXrjacquireris r# __enter__zAsyncAdaptedLock.__enter__sdjj00233r%c8|jjyr)rjrelease)r r'kws r#__exit__zAsyncAdaptedLock.__exit__s r%N)r.z asyncio.Lockr.r)r'rrprr.None)r/r0r1rrjrmrqrr%r#rfrfs 4 r%rfc 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. )r8get_running_loop RuntimeErrorget_event_loop_policyrTrr%r#rTrTsB  ''))      ( ( * 9 9 ;;s  ""cTeZdZUdZded<d dZd dZddZd dZddZ dd Z d d Z y )_Runnerz#Runner implementation for test onlyz6Union[None, asyncio.AbstractEventLoop, Literal[False]]_loopcd|_yr)rzris r#r$z_Runner.__init__s DJr%c&|j|Sr) _lazy_initris r#rmz_Runner.__enter__s OO Kr%c$|jyr)rI)r exc_typeexc_valexc_tbs r#rqz_Runner.__exit__s JJLr%c|jrV |jj|jj|jjd|_yy#|jjd|_wxYw)NF)rzrVshutdown_asyncgensrIris r#rIz _Runner.closesizz'JJ11 557JJ$$&!&DJ JJ$$&!&DJs 3A$$#BcV|j|jsJ|jS)zReturn embedded event loop.)r}rzris r#get_loopz_Runner.get_loops" OO :: ::: r%ct|j|jsJ|jj|Sr)r}rzrV)r coros r#runz _Runner.runs- OO :: :::006 6r%c|jdur td|jtj|_yy)NFzRunner is closed)rzrvr8new_event_loopris r#r}z_Runner._lazy_inits9zzU""#566zz!$335 "r%N)r.rs)r.r)rrrrrrr.rsr.zasyncio.AbstractEventLoop)rzCoroutine[Any, Any, _T]r.r) r/r0r1__doc__r2r$rmrqrIrrr}rr%r#ryrys.1EE    '   7  6r%ry)r.r)r;r[r.r)rFzAwaitable[_T_co]r.z%TypeGuard[Coroutine[Any, Any, _T_co]])rFzAwaitable[Any]r.rsrr)rFz Awaitable[_T]r.r) r!zCallable[..., _T]r_rrYrr`rr.rr), __future__rr8 contextvarsrr\typingrrrrr r r r langhelpersrrutilr util.typingrrrrrrr4hasattrr@r<r>rBrGrJrNrRrXrdrfrTRunnerryrr%r#rs:#  *!"# T]  8 &$! *, 50x0 4(4#4 .4 %%KG ,4,F!,, ,, ,  ,^   <nnG(6(6r%