e?1i ddlmZddlZddlmZddlZddlZddlmZddlmZddlm Z ddlm Z ddlm Z dd lm Z dd lm Z d d lmZd dlmZd dlmZd dlmZe dZejrGddeZd*dZn ddlmZddlmZeedZd+dZGddeZe ddZe r d,dZn ej:Zd-dZd.d Zd.d!Z d"d# d/d$Z!Gd%d&Z" d0d'Z# d0d(Z$d1d)Z%y)2) annotationsN)Context)Any) Awaitable)Callable) Coroutine)Optional) TYPE_CHECKING)TypeVar)memoized_property)exc)Protocol) TypeGuard_Tc:eZdZUded<ded<d dZd dZd dZy) greenletbooldeadzOptional[Context] gr_contextcyNselffndrivers k/home/www/therecruiter.miabetepe.com/venv/lib/python3.12/site-packages/sqlalchemy/util/_concurrency_py3k.py__init__zgreenlet.__init__$s cyrr)rargs rthrowzgreenlet.throw'r!cyrr)rvalues rswitchzgreenlet.switch*r%r!NrzCallable[..., Any]rr)r#rreturnr)r'rr*r)__name__ __module__ __qualname____annotations__r r$r(rr!rrr s %%   r!rcyrrrr!r getcurrentr0-s r!)r0)rrc|t|t xs*t|tjtjfSr) isinstance Exceptionasyncio TimeoutErrorCancelledError)es ris_exit_exceptionr8;s8!Y' ' : G '"8"8 9,r!c eZdZUded<ddZy)_AsyncIoGreenletrrcptj|||||_tr|j|_yyr)rr r_has_gr_contextrrs rr z_AsyncIoGreenlet.__init__Ks0$F+ $//DO r!Nr))r+r,r-r.r rr!rr:r:Hs J0r!r:_T_coT) covariantcyrr awaitables r iscoroutinerBVs r!c<t|r|jyyr)rBcloser@s r_safe_cancel_awaitablerE_s9r!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?)r0r2r:rErMissingGreenletrr()rAcurrents r await_onlyrIfsMlG g/ 0y)!! =   >>  ++r!ct}t|tsKt}|j r t |t jd|j|S|jj|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?) r0r2r:get_event_loop is_runningrErrGrun_until_completerr()rArHloops rawait_fallbackrOsplG 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:r0r(r BaseExceptionr$sysexc_inforr AwaitRequired)rrPargskwargscontextswitch_occurredresultr's rgreenlet_spawnr[s"r:<0G O00,,"O /% !.,, No G  M#%  8' 7  8 NsQB9 B2BBBB2#B9B*B/,B2.B//B22B66B9c.eZdZeddZddZddZy)AsyncAdaptedLockc*tjSr)r4Lockrs rmutexzAsyncAdaptedLock.mutexs||~r!cHt|jjSr)rOraacquirer`s r __enter__zAsyncAdaptedLock.__enter__sdjj00233r!c8|jjyr)rarelease)rr#kws r__exit__zAsyncAdaptedLock.__exit__s r!N)r*z asyncio.Lock)r*r)r#rrgrr*None)r+r,r-r rardrhrr!rr]r]s 4 r!r]czt}|jr td|j||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)rKrLr3rMrrVrWrNs r"_util_async_run_coroutine_functionrmsE  D  0    " "2t#6v#6 77r!ct}|js|jt|g|i|St t t sJ||i|S)rk)rKrLrMr[r2r0r:rls r_util_async_runros[  D ?? &&~b'J4'J6'JKK*,(89994"6""r!c 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. )r4get_running_loop RuntimeErrorget_event_loop_policyrKrr!rrKrKsB  ''))      ( ( * 9 9 ;;s  "")r*r)r7rRr*r)rAzAwaitable[_T_co]r*z%TypeGuard[Coroutine[Any, Any, _T_co]])rAzAwaitable[Any]r*ri)rAz Awaitable[_T]r*r) rzCallable[..., _T]rVrrPrrWrr*r)rz'Callable[..., Coroutine[Any, Any, Any]]rVrrWrr*r)r*zasyncio.AbstractEventLoop)& __future__rr4 contextvarsrrStypingrrrrr r r langhelpersr r util.typingrrrrr0hasattrr<r8r:r=rBrErIrOr[r]rmrorKrr!rr{sW#  *"# T]  8  $! *, 50x0 4( # . %%K,4,<!// // /  /d   8/ 88; 8GJ 8 8 #/ #8; #GJ # #