ޠjJ#SSKJr SSKrSSKrSSKJr SSKJr SSKJr SSKJr SSKJ r SSKJ r SS KJ r SS KJ r SS KJ r SS KJr SS KJr SSKJr SSKJr SSKJr SSKrSSKJr SSKJr SSKJr SSKJr \"S\S9r\"S\SS9r\"S\S9r"SS\ \5r"SS \\\R>5r "S!S"\ \5r!S&S#jr""S$S%\\5r#g)') 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*\rSrSr%0rS\S'Sr\SSj5r\SSj5rSSjr\ SSS jj5r \ SS j5r \\ SSS jj55r \\ SSS jj55r \ SSS jj5r Sr g)ReversibleProxy(zCClassVar[Dict[weakref.ref[Any], weakref.ref[ReversibleProxy[Any]]]]_proxy_objects) __weakref__cgNselftargets U/var/www/html/gaurav/venv/lib/python3.13/site-packages/sqlalchemy/ext/asyncio/base.py_assign_proxiedReversibleProxy._assign_proxied.s36cgr#r$r%s r(r)r*1s58r+cUbr[R"U[R5n[R"U[R "[RU55nU[R U'U$r#)weakrefrefr _target_gced functoolspartialr )r&r' target_ref proxy_refs r(r)r*4sb  +2;;44,J !!/">"> KI:CO * *: 6 r+Nc<URRUS5 gr#)r pop)clsr/r4s r(r0ReversibleProxy._target_gcedAs sD)r+c [5er#NotImplementedError)r7r' additional_kws r(_regenerate_proxy_for_target,ReversibleProxy._regenerate_proxy_for_targetIs "##r+c gr#r$r7r' regenerater<s r(_retrieve_proxy_for_target*ReversibleProxy._retrieve_proxy_for_targetOsr+c gr#r$r@s r(rBrCUsr+c UR[R"U5nU"5nUbU$U(aUR"U40UD6$g![a N'f=fr#)r r.r/KeyErrorr=)r7r'rAr<r4proxys r(rBrC[sk **7;;v+>?IKE  ! 33FLmL L   s#A AAr$)r'rreturnr)r'NonerHrI)r' Optional[_PT]rHrJr#)r/zweakref.ref[_PT]r4zOptional[weakref.ref[Self]]rHrI)r'rr<rrHr).)r'rrAz Literal[True]r<rrHr)T)r'rrAboolr<rrHzOptional[Self])__name__ __module__ __qualname____firstlineno__r __annotations__ __slots__rr) classmethodr0r=rB__static_attributes__r$r+r(rr(sT  !I 66 88 26* */*  **$$+.$ $$ 69&3LO -1&*DG -1&*DG r+rc\rSrSrSr\R S S Sjj5rS SjrS Sjr \R S Sj5r SSjr Sr g)StartableContextnr$c# [5e7fr#r:)r& is_ctxmanagers r(startStartableContext.startqs!##s c>UR5R5$r#)rY __await__r&s r(r\StartableContext.__await__uszz|%%''r+c<# URSS9IShvN $N7f)NT)rX)rYr]s r( __aenter__StartableContext.__aenter__xsZZdZ3333s c # g7fr#r$)r&type_value tracebacks r( __aexit__StartableContext.__aexit__{s  sc\[R"SURR-5e)Nz@%s context has not been started and object has not been awaited.) async_excAsyncContextNotStarted __class__rLr]s r(_raise_for_not_started'StartableContext._raise_for_not_starteds*.. N~~&& (  r+NFrXrKrHr)rHzGenerator[Any, Any, _T_co])rHr)rcrrdrrerrHOptional[bool])rHr ) rLrMrNrOrQabcabstractmethodrYr\r`rfrlrSr$r+r(rUrUnshI$$(4   !$ 14    r+rUcb\rSrSr%SrS\S'S SjrS S SjjrS SjrSr g) GeneratorStartableContextgenzAsyncGenerator[_T_co, Any]rwcU"U0UD6Ulgr#rv)r&funcargskwdss r(__init__"GeneratorStartableContext.__init__s &&r+c# [R"UR5IShvN nU(d"URR 5IShvN U$N/![a [ S5Sef=fN"7f)Nzgenerator didn't yield)ranext_rwStopAsyncIteration RuntimeErroraclose)r&rX start_values r(rYGeneratorStartableContext.startsh C $ DHH 55K((//# # #6! C78d B C $s7A5#AAA$A5A3A5AA00A5c# Uc4[R"UR5IShvN [S5eUcU"5nURR U5IShvN [S5eNH![a gf=fN!![a nXBLsSnA$SnAf[a>nXBLaSnAg[ U[[45(aURULaSnAgeSnAf[anXBLaeSnAgSnAff=f7f)Nzgenerator didn't stopFz$generator didn't stop after athrow()) rrrwrrathrow isinstance StopIteration __cause__ BaseException)r&typrdrers r(rf#GeneratorStartableContext.__aexit__s ; <kk$((+++##:;;}! hhooe,,,BEF FY,%  -% ('' < u}6H&IJJ .  # sC>#A5A3A5C>B#B$B( C>3A55 B?C>BC>B C;BC;C> C;&C*C>/*CC>C C;,C61C>6C;;C>N)ry#Callable[..., AsyncIterator[_T_co]]rzzTuple[Any, ...]r{zDict[str, Any]rnro)rrrdrrerrHrp) rLrMrNrOrQrPr|rYrfrSr$r+r(rtrts]I ##'1'' ' 2G2G"2G/22G 2Gr+rtcJ^[R"T5SU4Sjj5nU$)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: .. sourcecode:: text @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. c>[TX5$r#)rt)rzr{rys r(helper%asyncstartablecontext..helpers(t::r+)rzrr{rrHz GeneratorStartableContext[_T_co])r1wraps)ryrs` r(asyncstartablecontextrs(J__T;; Mr+c^\rSrSrSr\R SSj5rS SjrS Sjr S Sjr Sr g) ProxyComparableir$c[5er#r:r]s r(_proxiedProxyComparable._proxieds !##r+c[U5$r#)idr]s r(__hash__ProxyComparable.__hash__ s $xr+cl[XR5=(a URUR:H$r#rrkrr&others r(__eq__ProxyComparable.__eq__s( unn - 0 / r+cv[XR5(+=(d URUR:g$r#rrs r(__ne__ProxyComparable.__ne__s+5..1 1 /}}. r+N)rHr)rHint)rrrHrK) rLrMrNrOrQrro_non_memoized_propertyrrrrrSr$r+r(rrs.I ""$#$  r+r)ryrrHz/Callable[..., GeneratorStartableContext[_T_co]])$ __future__rrqr1typingrrrrrr r r r r rrrrr.rrir util.typingrrrrrrABCrUrtrrr$r+r(rs# ! " Tsd3e3CgclCL y' 4NG 0 7NGb) -)4)X oc* r+