o E6dT$@sddlmZddlZddlZddlmZddlmZddlmZddlmZddlm Z ddlm Z dd lm Z dd lm Z dd lm Z dd lmZdd lmZddlmZddlmZddlmZddlZddlmZddlmZddlmZddlmZededZededdZededZGddde eZGdd d eeejZ Gd!d"d"e eZ!d+d'd(Z"Gd)d*d*eeZ#dS),) annotationsN)Any)AsyncGenerator) AsyncIterator) Awaitable)Callable)ClassVar)Dict) Generator)Generic)NoReturn)Optional)overload)Tuple)TypeVar)exc)util)Literal)Self_T)bound_T_coT)r covariant_PTc@seZdZUiZded<dZed!ddZed"d dZd#d dZe d$d%ddZ ed&ddZ ee d'd(ddZ ee d)d*ddZ e d)d*d dZ d S)+ReversibleProxyzCClassVar[Dict[weakref.ref[Any], weakref.ref[ReversibleProxy[Any]]]]_proxy_objects) __weakref__targetrreturncCdSNselfrr#r#rC:\Users\jesus\OneDrive\Desktop\erpjis_fastapi\backend\jisbackend\Lib\site-packages\sqlalchemy/ext/asyncio/base.py_assign_proxied.zReversibleProxy._assign_proxiedNonecCr!r"r#r$r#r#r&r'2r( Optional[_PT]cCs:|durt|tj}t|ttj|}|tj|<|Sr")weakrefrefr _target_gced functoolspartialr)r%rZ target_ref proxy_refr#r#r&r'6s Nr,weakref.ref[_PT]r0Optional[weakref.ref[Self]]cCs|j|ddSr")rpop)clsr,r0r#r#r&r-EszReversibleProxy._target_gcedrcCtr"NotImplementedError)r4rr#r#r&_regenerate_proxy_for_targetMz,ReversibleProxy._regenerate_proxy_for_target. regenerate Literal[True]cCr!r"r#r4rr:r#r#r&_retrieve_proxy_for_targetQsz*ReversibleProxy._retrieve_proxy_for_targetTboolOptional[Self]cCr!r"r#r<r#r#r&r=ZscCsLz |jt|}Wn tyYn w|}|dur|S|r$||SdSr")rr+r,KeyErrorr8)r4rr:r0proxyr#r#r&r=as  )rrr r)rr)r r))rr*r r*r")r,r1r0r2r r))rrr r).)rrr:r;r r)T)rrr:r>r r?) __name__ __module__ __qualname__r__annotations__ __slots__rr' classmethodr-r8r=r#r#r#r&r(s2      rc@sPeZdZdZejddddZdd d Zdd d ZejdddZ dddZ dS)StartableContextr#F is_ctxmanagerr>r rcstr"r6)r%rIr#r#r&startwszStartableContext.startGenerator[Any, Any, _T_co]cCs |Sr")rJ __await__r%r#r#r&rL{s zStartableContext.__await__cs|jddIdHS)NT)rI)rJrMr#r#r& __aenter__~szStartableContext.__aenter__type_rvalue tracebackOptional[bool]csdSr"r#)r%rOrPrQr#r#r& __aexit__szStartableContext.__aexit__r cCstd|jj)Nz@%s context has not been started and object has not been awaited.) async_excZAsyncContextNotStarted __class__rBrMr#r#r&_raise_for_not_starteds z'StartableContext._raise_for_not_startedNFrIr>r r)r rK)r r)rOrrPrrQrr rR)r r ) rBrCrDrFabcabstractmethodrJrLrNrSrVr#r#r#r&rHts   rHc@s:eZdZUdZded<dd d ZddddZdddZdS)GeneratorStartableContextgenzAsyncGenerator[_T_co, Any]r]func#Callable[..., AsyncIterator[_T_co]]argsTuple[Any, ...]kwdsDict[str, Any]cCs||i||_dSr"r\)r%r^r`rbr#r#r&__init__sz"GeneratorStartableContext.__init__FrIr>r rcsJz t|jIdH}Wn tytddw|s#|jIdH|S)Nzgenerator didn't yield)ranext_r]StopAsyncIteration RuntimeErroraclose)r%rIZ start_valuer#r#r&rJs  zGeneratorStartableContext.starttyprrPrQrRc s|durzt|jIdHWtdtyYdSw|dur%|}zt|j|||IdHWtdtyL}z ||uWYd}~Sd}~wtyv}z||ur^WYd}~dSt|ttfrq|j|urqWYd}~dSd}~wt y}z ||urWYd}~dSd}~ww)NFzgenerator didn't stopz$generator didn't stop after athrow()) rrer]rfrgathrow isinstance StopIteration __cause__ BaseException)r%rirPrQrr#r#r&rSs> !  z#GeneratorStartableContext.__aexit__N)r^r_r`rarbrcrWrX)rirrPrrQrr rR)rBrCrDrFrErdrJrSr#r#r#r&r[s   r[r^r_r /Callable[..., GeneratorStartableContext[_T_co]]cstd fdd }|S) a$@asyncstartablecontext decorator. the decorated function can be called either as ``async with fn()``, **or** ``await fn()``. This is decidedly different from what ``@contextlib.asynccontextmanager`` supports, and the usage pattern is different as well. Typical usage:: @asyncstartablecontext async def some_async_generator(): try: yield except GeneratorExit: # return value was awaited, no context manager is present # and caller will .close() the resource explicitly pass else: Above, ``GeneratorExit`` is caught if the function were used as an ``await``. In this case, it's essential that the cleanup does **not** occur, so there should not be a ``finally`` block. If ``GeneratorExit`` is not invoked, this means we're in ``__aexit__`` and we were invoked as a context manager, and cleanup should proceed. r`rrbr GeneratorStartableContext[_T_co]cs t||Sr")r[)r`rbr^r#r&helpers z%asyncstartablecontext..helperN)r`rrbrr rp)r.wraps)r^rrr#rqr&asyncstartablecontexts#rtc@s>eZdZdZejdddZdddZdd d ZdddZ dS)ProxyComparabler#r rcCr5r"r6rMr#r#r&_proxied r9zProxyComparable._proxiedintcCst|Sr")idrMr#r#r&__hash__szProxyComparable.__hash__otherrr>cCst||jo |j|jkSr"rkrUrvr%rzr#r#r&__eq__s  zProxyComparable.__eq__cCst||j p |j|jkSr"r{r|r#r#r&__ne__s zProxyComparable.__ne__N)r r)r rw)rzrr r>) rBrCrDrFrZro_non_memoized_propertyrvryr}r~r#r#r#r&ru s   ru)r^r_r ro)$ __future__rrYr.typingrrrrrrr r r r r rrrr+rrTrZ util.typingrrrrrrABCrHr[rtrur#r#r#r&s<                     L Q*