h#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 l/var/www/html/retail-simulation-api/retail/lib/python3.12/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<ddZy)_AsyncIoGreenletrrcptj|||||_tr|j|_yyr)rr$r"_has_gr_contextrrs r#r$z_AsyncIoGreenlet.__init__Ms0$F+ $//DO r%Nr-)r/r0r1r2r$rr%r#r>r>Js J0r%r>_T_coT) covariantcyrr awaitables r# iscoroutinerFXs03r%c<t|r|jyyr)rFcloserDs r#_safe_cancel_awaitablerI`s9r%c6t}t|tSr)r4r6r>)currents r# in_greenletrLgslG g/ 00r%ct}t|ts t|t j d|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. zjgreenlet_spawn has not been called; can't call await_only() here. Was IO attempted in an unexpected place?)r4r6r>rIrMissingGreenletr"r,)rErKs r# await_onlyrOlsMlG g/ 0y)!! =   >>  ++r%ct}t|tsKt}|j r t |t jd|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`. 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?) r4r6r>get_event_loop is_runningrIrrNrun_until_completer"r,)rErKloops r#await_fallbackrUsp lG g/ 0 ??  "9 -%%;  &&y11 >>  ++r%F)_require_awaitcvKt|t}d} |j|i|}|js+d} |d{}|j|}|js+|`|r|stjd|S7?#t$r$|j t j}YXwxYw#|`wxYww)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"r AwaitRequired)r!rVargskwargscontextswitch_occurredresultr+s r#greenlet_spawnras"r:<0G O00,,"O /% !.,, No G  M#%  8' 7  8 NsQB9 B2BBBB2#B9B*B/,B2.B//B22B66B9c.eZdZeddZddZddZy)AsyncAdaptedLockc*tjSr)r8Lockr s r#mutexzAsyncAdaptedLock.mutexs||~r%cHt|jjSr)rUrgacquirerfs r# __enter__zAsyncAdaptedLock.__enter__sdjj00233r%c8|jjyr)rgrelease)r r'kws r#__exit__zAsyncAdaptedLock.__exit__s r%N)r.z asyncio.Lockr.r)r'rrmrr.None)r/r0r1rrgrjrnrr%r#rcrcs 4 r%rcc 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_policyrQrr%r#rQrQsB  ''))      ( ( * 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)rwrfs r#r$z_Runner.__init__s DJr%c&|j|Sr) _lazy_initrfs r#rjz_Runner.__enter__s OO Kr%c$|jyr)rH)r exc_typeexc_valexc_tbs r#rnz_Runner.__exit__s JJLr%c|jrV |jj|jj|jjd|_yy#|jjd|_wxYw)NF)rwrSshutdown_asyncgensrHrfs r#rHz _Runner.close sizz'JJ11 557JJ$$&!&DJ JJ$$&!&DJs 3A$$#BcV|j|jsJ|jS)zReturn embedded event loop.)rzrwrfs r#get_loopz_Runner.get_loops" OO :: ::: r%ct|j|jsJ|jj|Sr)rzrwrS)r coros r#runz _Runner.runs- OO :: :::006 6r%c|jdur td|jtj|_yy)NFzRunner is closed)rwrsr8new_event_looprfs r#rzz_Runner._lazy_inits9zzU""#566zz!$335 "r%N)r.rp)r.r)r|rr}rr~rr.rpr.zasyncio.AbstractEventLoop)rzCoroutine[Any, Any, _T]r.r) r/r0r1__doc__r2r$rjrnrHrrrzrr%r#rvrvs.1EE    '   7  6r%rv)r.r)r;rXr.r)rEzAwaitable[_T_co]r.z%TypeGuard[Coroutine[Any, Any, _T_co]])rEzAwaitable[Any]r.rpro)rEz Awaitable[_T]r.r) r!zCallable[..., _T]r\rrVrr]rr.rr), __future__rr8 contextvarsrrYtypingrrrrr r r r langhelpersrrutilr util.typingrrrrrrr4hasattrr@r<r>rArFrIrLrOrUrarcrQRunnerrvrr%r#rs9#  *!"# T]  8 &$! *, 50x0 4(4#4 .4 %%K1 ,4,F!// // /  /d   <nnG(6(6r%