Ë

����£éfI��ã������������������óN��—�U�d�dl�mZ�d�dlZd�dlmZ�d�dlmZmZmZm	Z	m
Z
�d�dlmZ�ddl
mZ��e	d«������Z�e	d	«������Zdd
„Zdd„Zdd„Zdd
„Z�e«�������Zded<���i�Zded<����ed¬«�������G�d„�d«������«�������Z�G�d„�dej2������������������«������Z�G�d„�dee���«������Z�G�d„�dee���«������Zy)é����)ÚannotationsN)Ú	dataclass)ÚAnyÚGenericÚLiteralÚTypeVarÚoverload)ÚWeakKeyDictionaryé���)Úget_async_backendÚTÚDc���������������ƒ��óP���K��—�t��������«�������j������������������«�������ƒ�d{��–—†��y7�Œ­w)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)r���Ú
checkpoint©�ó����úW/var/lib/jenkins/workspace/mettalog/venv/lib/python3.12/site-packages/anyio/lowlevel.pyr���r������s���è�ø€�ô�Ó
×
(Ñ
(Ó
*×*Ò*úó���‚&ž$Ÿ&c���������������ƒ��óP���K��—�t��������«�������j������������������«�������ƒ�d{��–—†��y7�Œ­w)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)r���Úcheckpoint_if_cancelledr���r���r���r���r������s���è�ø€�ô�Ó
×
5Ñ
5Ó
7×7Ò7úr���c���������������ƒ��óP���K��—�t��������«�������j������������������«�������ƒ�d{��–—†��y7�Œ­w)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)r���Úcancel_shielded_checkpointr���r���r���r���r���*���s���è�ø€�ô�Ó
×
8Ñ
8Ó
:×:Ò:úr���c�����������������ó2���—�t��������«�������j������������������«�������S�)ze
    Return a backend specific token object that can be used to get back to the event
    loop.

    )r���Ú
current_tokenr���r���r���r���r���:���s���€�ô�Ó×,Ñ,Ó.Ð.r���z&WeakKeyDictionary[Any, dict[str, Any]]Ú	_run_varszdict[Any, _TokenWrapper]Ú_token_wrappersT)Úfrozenc������������������ó���—�e�Zd�ZU�dZded<���y)Ú
_TokenWrapper)Ú_tokenÚ__weakref__Úobjectr ���N)Ú__name__Ú
__module__Ú__qualname__Ú	__slots__Ú__annotations__r���r���r���r���r���G���s���…�à'€IØ„Nr���r���c������������������ó.���—�e�Zd�Z�ej������������������«�������Zy)Ú_NoValueSetN)r#���r$���r%���ÚenumÚautoÚNO_VALUE_SETr���r���r���r)���r)���M���s���„�ؐ4—9‘9“;Lr���r)���c������������������ó���—�e�Zd�ZdZdd„Zy)ÚRunvarToken©Ú_varÚ_valueÚ	_redeemedc����������������ó.���—�||�_���������||�_��������d|�_��������y�)NFr/���)ÚselfÚvarÚvalues���   r���Ú__init__zRunvarToken.__init__T���s���€�؈Œ	Ø=BˆŒØˆr���N)r5���z	RunVar[T]r6���ú%T | Literal[_NoValueSet.NO_VALUE_SET])r#���r$���r%���r&���r7���r���r���r���r.���r.���Q���s���„�Ø-€Iôr���r.���c������������������óÂ���—�e�Zd�ZU�dZdZej������������������Zded<����e«�������Z	ded<���ef	�	�	�dd„Z
edd„«�������Ze
dd	„«�������Ze
dd
„«�������Zef	�	�	�dd„Zdd„Zdd
„Zdd„Zy)ÚRunVarz[
    Like a :class:`~contextvars.ContextVar`, except scoped to the running event loop.
    ©Ú_nameÚ_defaultz!Literal[_NoValueSet.NO_VALUE_SET]r,���zset[_TokenWrapper]r���c����������������ó ���—�||�_���������||�_��������y�©Nr;���)r4���ÚnameÚdefaults���   r���r7���zRunVar.__init__e���s���€�ð�ˆŒ
؈
r���c����������������ób���—�t��������«�������}	�t��������|���S�#�t��������$�r�i�x}t��������|<���|cY�S�w�xY�wr?���)r���r���ÚKeyError)r4���ÚtokenÚrun_varss���   r���Ú
_current_varszRunVar._current_varsk���s<���€�䓈ð	ܘUÑ#Ð#øÜò�	Ø*,Ð,ˆH”y Ñ'ØŠOð	ús���Œ�•.­.c�����������������ó���—�y�r?���r���©r4���rA���s���  r���Úgetz
RunVar.gett���s���€�Ø(+r���c�����������������ó���—�y�r?���r���©r4���s��� r���rI���z
RunVar.getw���s���€�Ør���c����������������ó��—�	�|�j�������������������|�j���������������������S�#�t��������$�rC�|t��������j������������������ur|cY�S�|�j
������������������t��������j������������������ur|�j
������������������cY�S�Y�nw�xY�wt
��������d|�j������������������›�d«������‚)NzRun variable "z!" has no value and no default set)rF���r<���rC���r:���r,���r=���ÚLookupErrorrH���s���  r���rI���z
RunVar.getz���s���€�ð	%Ø×%Ñ% d§j¡jÑ1Ð1øÜò�	%Øœf×1Ñ1Ñ1ؒؗ‘¤f×&9Ñ&9Ñ9Ø—}‘}Ò$ñ�:ð	%úô�ؘTŸZ™Z˜LÐ(IÐJó
ð�	
s���‚�›A'º(A'Á&A'c����������������ó¤���—�|�j�������������������}t��������|�|j������������������|�j������������������t��������j
������������������«������«������}|||�j������������������<���|S�r?���)rF���r.���rI���r<���r:���r,���)r4���r6���Úcurrent_varsrD���s���    r���Úsetz
RunVar.set‰���sC���€�Ø×)Ñ)ˆܘD ,×"2Ñ"2°4·:±:¼v×?RÑ?RÓ"SÓTˆØ#(ˆT—Z‘ZÑ Øˆr���c����������������ó\��—�|j�������������������|�urt��������d«������‚|j������������������rt��������d«������‚|j������������������t��������j
������������������u�r 	�|�j������������������|�j������������������=�d|_��������y�|j������������������|�j������������������|�j������������������<���d|_��������y�#�t��������$�r
�Y�d|_��������y�w�xY�w)Nz)This token does not belong to this RunVarz This token has already been usedT)	r0���Ú
ValueErrorr2���r1���r)���r,���rF���r<���rC���)r4���rD���s���  r���ÚresetzRunVar.reset���s���€�؏:‰:˜TÑ!ÜÐHÓIÐIà?Š?ÜÐ?Ó@Ð@à<‰<œ;×3Ñ3Ñ3ð
Ø×&Ñ& t§z¡zÐ2ð�ˆð�.3¯\©\ˆD×Ñ˜tŸz™zÑ*àˆøô�ò�
Øð�ˆð
ús���ÁB�Â	B+Â*B+c����������������ó"���—�d|�j�������������������›dS�)Nz
<RunVar name=ú>)r<���rK���s��� r���Ú__repr__zRunVar.__repr__ ���s���€�ؘtŸz™z˜n¨AÐ.Ð.r���N)r@���ÚstrrA���r8���)Úreturnzdict[str, T])rA���r���rX���úT | D)rX���r
���)rA���z%D | Literal[_NoValueSet.NO_VALUE_SET]rX���rY���)r6���r
���rX���úRunvarToken[T])rD���rZ���rX���ÚNone)rX���rW���)r#���r$���r%���Ú__doc__r&���r)���r,���r'���rP���r���r7���ÚpropertyrF���r	���rI���rS���rV���r���r���r���r:���r:���Z���s¥���…�ñð�$€Ià6A×6NÑ6N€LÐ3ÓNá*-«%€OÐ'Ó/ð�KWð Øð Ø"Gó ð�òó�ðð�Ú+ó�Ø+à
Úó�Øð�@Lð

Ø<ð

à	ó

óóô"/r���r:���)rX���r[���)rX���r"���)Ú
__future__r���r*���Údataclassesr���Útypingr���r���r���r���r	���Úweakrefr
���Ú_core._eventloopr���r
���r���r���r���r���r���r���r'���r���r���ÚEnumr)���r.���r:���r���r���r���ú<module>rd������s¬���ðÞ�"ã�Ý�!ß�;Õ�;Ý�%å�/áˆCƒL€ÙˆCƒL€ó
+ó 	8ó
;ó /ñ�5FÓ4G€	Ð1Ó�GØ,.€Ð)Ó�.ñ�$Ô÷ð�ó�ðô
$—)‘)ô�ô'˜!‘*ô�ôG/ˆWQ‰Zõ�G/r���