etj#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 _/var/www/html/CA-Chatbot/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<dZd dZd S) _AsyncIoGreenletrrTrrrrc\tj|||tr|j|_dSdSr )rr%_has_gr_contextrr"s r$r%z_AsyncIoGreenlet.__init__Os7$F+++  0$/DOOO 0 0r'Nr0)r1r2r3r4 __sqlalchemy_greenlet_provider__r%r!r'r$rArAJs9JJJ'+$000000r'rA_T_coT) covariant awaitableAwaitable[_T_co]%TypeGuard[Coroutine[Any, Any, _T_co]]cdSr r!rGs r$ iscoroutinerLYs03r'Awaitable[Any]NonecPt|r|dSdSr )rLcloserKs r$_safe_cancel_awaitablerQas49r'c@t}t|ddS)NrDF)r6getattr)currents r$ in_greenletrUhsllG 7> F FFr' Awaitable[_T]ct}t|dds#t|tjd|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. rDFzjgreenlet_spawn has not been called; can't call await_only() here. Was IO attempted in an unexpected place?)r6rSrQrMissingGreenletparentr/)rGrTs r$ await_onlyrZmsbllG 7> F F y)))! =    >  + ++r'c(t}t|ddsZt}|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`. rDFzgreenlet_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?) r6rSget_event_loop is_runningrQrrXrun_until_completerYr/)rGrTloops r$await_fallbackr`s llG 7> F F 2 ??    "9 - - -%;  &&y111 >  + ++r'F)_require_awaitrCallable[..., _T]argsrrakwargscDKt|t}d}|j|i|}|jsSd} |d{V}||}n+#t$r|jt j}YnwxYw|jS|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_infor AwaitRequired)rrarcrdcontextswitch_occurredresultr-s r$greenlet_spawnrls"r:<<00G O W^T ,V , ,Fl + +!LLLLLLE^^E**FF  4 4 4#W]CLNN3FFF  4 l + o  G   MsA%A>=A>c6eZdZed dZd dZdd Zd S)AsyncAdaptedLockr) asyncio.Lockc(tjSr )r<Lockr#s r$mutexzAsyncAdaptedLock.mutexs|~~r'rcNt|jSr )r`rsacquirerrs r$ __enter__zAsyncAdaptedLock.__enter__s dj0022333r'r(rkwrNc8|jdSr )rsrelease)r#r(rws r$__exit__zAsyncAdaptedLock.__exit__s r'N)r)ror)r)r(rrwrr)rN)r1r2r3rrsrvrzr!r'r$rnrns[ 4444 r'rnasyncio.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_policyr\r!r'r$r\r\sS  ')))        ( * * 9 9 ; ;;s  ""cVeZdZUdZded<ddZddZdd ZddZddZ ddZ ddZ dS)_Runnerz#Runner implementation for test onlyz6Union[None, asyncio.AbstractEventLoop, Literal[False]]_loopr)rNcd|_dSr )rrrs r$r%z_Runner.__init__s DJJJr'rc.||Sr ) _lazy_initrrs r$rvz_Runner.__enter__s OO   Kr'exc_typerexc_valexc_tbc.|dSr )rP)r#rrrs r$rzz_Runner.__exit__s JJLLLLLr'c|jry |j|j|jd|_dS#|jd|_wxYwdS)NF)rr^shutdown_asyncgensrPrrs r$rPz _Runner.closesz ''J11 5577J$$&&&!&DJJJJ$$&&&!&DJ&&&& ' 's 1A"A>r|cJ||jsJ|jS)zReturn embedded event loop.)rrrrs 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)rrr<new_event_looprrs r$rz_Runner._lazy_initsBzU"""#5666z!$355 "!r'N)r)rN)r)r)rrrrrrr)rNr)r|)rrr)r) r1r2r3__doc__r4r%rvrzrPrrrr!r'r$rrs11EEEE             ' ' ' '      7 7 7 7  6 6 6 6 6 6r'r)r)r)r7r8r)r)rGrHr)rI)rGrMr)rNr{)rGrVr)r) rrbrcrrarrdrr)rr), __future__rr< contextvarsrrftypingrrrrr r r r langhelpersrrutilr util.typingrrrrrrr6hasattrrCr?rArErLrQrUrZr`rlrnr\Runnerrr!r'r$rsh#"""""  ******!!!!!!""""""###### WT]] "     8   &%%%%$#####!!!!!! '**,, 5500000x000 4(((&44444 %KGGGG ,,,,4,,,,F!,,,,,,^         < < < <,6,6nGGG(6(6(6(6(6(6(6(6(6(6r'