ցj%SSKJr SrSSKrSSKJr SSKJr SSKJ r J r J r J r J r JrJr SSKJr SS KJr \ (aSS KJr \ "S 5r\ "S 5rSS jrSSjrSSjr\\"SSS9"SS555rSSjr\"5rS\S'"SS\R>5r "SS\ \5r!"SS\ \5r"g) ) annotations)EventLoopToken RunvarTokenRunVar checkpointcheckpoint_if_cancelledcancel_shielded_checkpoint current_tokenN) dataclass) TracebackType) TYPE_CHECKINGAnyGenericLiteralTypeVarfinaloverload)WeakKeyDictionary)get_async_backend) AsyncBackendTDcP# [5R5IShvN gN7f)z Check for cancellation and allow the scheduler to switch to another task. Equivalent to (but more efficient than):: await checkpoint_if_cancelled() await cancel_shielded_checkpoint() .. versionadded:: 3.0 N)rrH/mnt/workspace/venv-train/lib/python3.13/site-packages/anyio/lowlevel.pyrrs   ( ( *** &$&cP# [5R5IShvN gN7f)z Enter a checkpoint if the enclosing cancel scope has been cancelled. This does not allow the scheduler to switch to a different task. .. versionadded:: 3.0 N)rrrrrrr+s   5 5 777rcP# [5R5IShvN gN7f)z Allow the scheduler to switch to another task but without checking for cancellation. Equivalent to (but potentially more efficient than):: with CancelScope(shield=True): await checkpoint() .. versionadded:: 3.0 N)rr rrrr r 7s   8 8 :::rTF)frozenreprc.\rSrSr%SrS\S'S\S'Srg) rFzU An opaque object that holds a reference to an event loop. .. versionadded:: 4.11.0 ztype[AsyncBackend] backend_classobject native_tokenrN)__name__ __module__ __qualname____firstlineno____doc____annotations____static_attributes__rrrrrFs &%rrcL[5nUR5n[X5$)z Return a token object that can be used to call code in the current event loop from another thread. :raises NoEventLoopError: if no supported asynchronous event loop is running in the current thread .. versionadded:: 4.11.0 )rr r)r% raw_tokens rr r Ss%&'M++-I - 33rz1WeakKeyDictionary[object, dict[RunVar[Any], Any]] _run_varsc6\rSrSr\R "5rSrg) _NoValueSetfrN)r(r)r*r+enumauto NO_VALUE_SETr.rrrr3r3fs 99;Lrr3cJ\rSrSrSrSrS SjrS SjrS SjrSr g) rjz A token that can be used to restore a :class:`RunVar` to its previous value. Returned by :meth:`RunVar.set`. Can be used as a context manager to automatically reset the variable on exit, or passed directly to :meth:`RunVar.reset`. _var_value _redeemedc*XlX lSUlg)NFr:)selfvarvalues r__init__RunvarToken.__init__ts =B rcU$Nrr?s r __enter__RunvarToken.__enter__ys rc:URRU5 grE)r;reset)r?exc_typeexc_valexc_tbs r__exit__RunvarToken.__exit__|s r)r=r<r;N)r@z RunVar[T]rA%T | Literal[_NoValueSet.NO_VALUE_SET])returnRunvarToken[T])rKztype[BaseException] | NonerLzBaseException | NonerMzTracebackType | NonerQNone) r(r)r*r+r, __slots__rBrGrNr.rrrrrjsC.I ,&%   rrc\rSrSr%SrSr\RrS\S'\4SSjjr \ SSj5r \ SSj5r \ SS j5r \4SS jjr SS jrSS jrSS jrSrg)rz Like a :class:`~contextvars.ContextVar`, except scoped to the running event loop. Can be used as a context manager, Just like :class:`~contextvars.ContextVar`, that will reset the variable to its previous value when the context block is exited. _name_defaultz!Literal[_NoValueSet.NO_VALUE_SET]r7cXlX lgrErW)r?namedefaults rrBRunVar.__init__s  rcx[5Rn[U$![a 0=n[U'Us$f=frE)r r'r1KeyError)r?r'run_varss r _current_varsRunVar._current_varssB$33  \* * 13 3Hy.O s 99cgrErr?r\s rget RunVar.gets(+rcgrErrFs rrerfsrcURU$![aE U[RLaUs$UR[RLaURs$Of=f[ SUR S35e)a  Return the current value of this run variable. :param default: a fallback value to return if no value has been set :return: the current value, the provided default, or the variable's own default :raises LookupError: if no value is set and no default is available zRun variable "z!" has no value and no default set)rar_rr7rY LookupErrorrXrds rrerfs{ %%%d+ + %f111f&9&99}}$: % TZZL(I J  sA )A A cxURn[XRU[R55nXU'U$)z Set the value of this run variable for the current event loop. :param value: the new value :return: a token that can be used to restore the previous value )rarrerr7)r?rA current_varstokens rset RunVar.sets9)) D"2"249L9L"MN"T rc(URULa [S5eUR(a [S5eUR[R LaUR U OURUR U'SUlg![a Nf=f)z Restore this run variable to the value it held before the matching :meth:`set`. :param token: the token returned by :meth:`set` :raises ValueError: if the token belongs to a different :class:`RunVar` or the token has already been used z)This token does not belong to this RunVarz This token has already been usedTN)r; ValueErrorr=r<r3r7rar_)r?rls rrJ RunVar.resets ::T !HI I ???@ @ <<;33 3 &&t,(-||D  t $   s B BBc$SUR<S3$)Nz )rXrFs r__repr__RunVar.__repr__stzznA..r)rYrXN)r[strr\rP)rQzdict[RunVar[T], T])r\rrQT | D)rQr)r\z%D | Literal[_NoValueSet.NO_VALUE_SET]rQrw)rArrQrR)rlrRrQrS)rQrv)r(r)r*r+r,rTr3r7r-rBpropertyrarrermrJrtr.rrrrrs$I6A6N6NL3NKW  "G ++ @L <  . 2/rr)rQrS)rQr)# __future__r__all__r5 dataclassesr typesr typingr rrrrrrweakrefr_core._eventlooprabcrrrrrr rr r1r-Enumr3rrrrrrs"  !QQQ%/! CL CL + 8 ; $U#$ 4 @Q?R <R$))'!*6_/WQZ_/r