§
     @g'  ã                  ó¼  — U d dl mZ d dlZd dlZd dlmZ d dlmZmZm	Z	m
Z
 d dlmZ ddlmZ ej        dk    rd d	lmZ nd d	lmZ  e	d
¦  «        Z e	d¦  «        Zd!d„Zd!d„Zd!d„Zd"d„Z e¦   «         Zded<   i Zded<    ed¬¦  «         G d„ d¦  «        ¦   «         Z G d„ dej        ¦  «        Z G d„ dee         ¦  «        Z G d„ d ee         ¦  «        ZdS )#é    )ÚannotationsN)Ú	dataclass)ÚAnyÚGenericÚTypeVarÚoverload)ÚWeakKeyDictionaryé   )Úget_asynclib)é   é   )ÚLiteralÚTÚDÚreturnÚNonec               ƒ  óV   K  — t          ¦   «                              ¦   «         ƒ d{V —† dS )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© ó    úB/var/www/piapp/venv/lib/python3.11/site-packages/anyio/lowlevel.pyr   r      s6   è è € õ ‰.Œ.×
#Ò
#Ñ
%Ô
%Ð%Ð%Ð%Ð%Ð%Ð%Ð%Ð%Ð%r   c               ƒ  óV   K  — t          ¦   «                              ¦   «         ƒ d{V —† dS )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   $   s6   è è € õ ‰.Œ.×
0Ò
0Ñ
2Ô
2Ð2Ð2Ð2Ð2Ð2Ð2Ð2Ð2Ð2r   c               ƒ  óV   K  — t          ¦   «                              ¦   «         ƒ d{V —† dS )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   0   s6   è è € õ ‰.Œ.×
3Ò
3Ñ
5Ô
5Ð5Ð5Ð5Ð5Ð5Ð5Ð5Ð5Ð5r   Úobjectc                 óB   — t          ¦   «                              ¦   «         S )zVReturn 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_varszdict[Any, _TokenWrapper]Ú_token_wrappersT)Úfrozenc                  ó   — e Zd ZU dZded<   dS )Ú_TokenWrapper)Ú_tokenÚ__weakref__r   r$   N)Ú__name__Ú
__module__Ú__qualname__Ú	__slots__Ú__annotations__r   r   r   r#   r#   I   s   € € € € € € à'€IØ€N€N�N€N€Nr   r#   c                  ó,   — e Zd Z ej        ¦   «         ZdS )Ú_NoValueSetN)r&   r'   r(   ÚenumÚautoÚNO_VALUE_SETr   r   r   r,   r,   O   s   € € € € € Ø�4”9‘;”;€L€L€Lr   r,   c                  ó   — e Zd ZdZdd„ZdS )	ÚRunvarToken©Ú_varÚ_valueÚ	_redeemedÚvarú	RunVar[T]Úvalueú%T | Literal[_NoValueSet.NO_VALUE_SET]c                ó0   — || _         || _        d| _        d S )NFr2   )Úselfr6   r8   s      r   Ú__init__zRunvarToken.__init__V   s   € ØˆŒ	Ø=BˆŒØˆŒˆˆr   N)r6   r7   r8   r9   )r&   r'   r(   r)   r<   r   r   r   r1   r1   S   s-   € € € € € Ø-€Iðð ð ð ð ð r   r1   c                  óÆ   — e Zd ZU dZdZej        Zded<    e¦   «         Z	ded<   efdd„Z
edd„¦   «         Zed d„¦   «         Zed!d„¦   «         Zefd"d„Zd#d„Zd$d„Zd%d„ZdS )&ÚRunVarz[
    Like a :class:`~contextvars.ContextVar`, except scoped to the running event loop.
    ©Ú_nameÚ_defaultz!Literal[_NoValueSet.NO_VALUE_SET]r/   zset[_TokenWrapper]r    ÚnameÚstrÚdefaultr9   c                ó"   — || _         || _        d S ©Nr?   )r;   rB   rD   s      r   r<   zRunVar.__init__g   s   € ð
 ˆŒ
ØˆŒˆˆr   r   údict[str, T]c                óâ   — t          ¦   «         }	 	 t          |         S # t          $ r, t          |¦  «        }| j                             |¦  «         Y nt          $ r i x}t          |<   |cY S w xY wŒarF   )r   r   Ú	TypeErrorr#   r    ÚaddÚKeyError)r;   ÚtokenÚrun_varss      r   Ú_current_varszRunVar._current_varso   s–   € å‘”ˆð	 ð
 Ý  Ô'Ð'øÝð 0ð 0ð 0õ & eÑ,Ô,�ØÔ$×(Ò(¨Ñ/Ô/Ð/Ð/Ð/Ýð  ð  ð  Ø.0Ð0��9 UÑ+Ø���ð øøøð	 s   ‘ ž3A-ÁA-Á,A-r   úT | Dc                ó   — d S rF   r   ©r;   rD   s     r   Úgetz
RunVar.get   ó   € àˆr   r   c                ó   — d S rF   r   ©r;   s    r   rR   z
RunVar.getƒ   rS   r   ú%D | Literal[_NoValueSet.NO_VALUE_SET]c                óÔ   — 	 | j         | j                 S # t          $ r1 |t          j        ur|cY S | j        t          j        ur	| j        cY S Y nw xY wt          d| j        › d�¦  «        ‚)NzRun variable "z!" has no value and no default set)rN   r@   rK   r>   r/   rA   ÚLookupErrorrQ   s     r   rR   z
RunVar.get‡   s“   € ð	%ØÔ% d¤jÔ1Ð1øÝð 	%ð 	%ð 	%Ø�fÔ1Ð1Ð1Ø���Ø”¥fÔ&9Ð9Ð9Ø”}Ð$Ð$Ð$ð :Ð9ð	%øøøõ ØJ˜TœZÐJÐJÐJñ
ô 
ð 	
s   ‚ ”A°AÁAr8   úRunvarToken[T]c                óŽ   — | j         }t          | |                     | j        t          j        ¦  «        ¦  «        }||| j        <   |S rF   )rN   r1   rR   r@   r>   r/   )r;   r8   Úcurrent_varsrL   s       r   Úsetz
RunVar.set–   s?   € ØÔ)ˆÝ˜D ,×"2Ò"2°4´:½vÔ?RÑ"SÔ"SÑTÔTˆØ#(ˆ�T”ZÑ Øˆr   rL   r   c                óü   — |j         | urt          d¦  «        ‚|j        rt          d¦  «        ‚|j        t          j        u r	 | j        | j        = n$# t          $ r Y nw xY w|j        | j        | j        <   d|_        d S )Nz)This token does not belong to this RunVarz This token has already been usedT)	r3   Ú
ValueErrorr5   r4   r,   r/   rN   r@   rK   )r;   rL   s     r   ÚresetzRunVar.resetœ   s›   € ØŒ:˜TÐ!Ð!ÝÐHÑIÔIÐIàŒ?ð 	AÝÐ?Ñ@Ô@Ð@àŒ<�;Ô3Ð3Ð3ðØÔ& t¤zÐ2Ð2øÝð ð ð Ø�ðøøøð .3¬\ˆDÔ˜tœzÑ*àˆŒˆˆs   ÁA Á
AÁAc                ó   — d| j         ›d�S )Nz<RunVar name=ú>)r@   rU   s    r   Ú__repr__zRunVar.__repr__­   s   € Ø.˜tœzÐ.Ð.Ð.Ð.r   N)rB   rC   rD   r9   )r   rG   )rD   r   r   rO   )r   r   )rD   rV   r   rO   )r8   r   r   rY   )rL   rY   r   r   )r   rC   )r&   r'   r(   Ú__doc__r)   r,   r/   r*   r\   r    r<   ÚpropertyrN   r   rR   r_   rb   r   r   r   r>   r>   \   s-  € € € € € € ðð ð $€Ià6AÔ6N€LÐNÐNÐNÑNà*-¨#©%¬%€OÐ/Ð/Ð/Ñ/ð
 :Fð ð  ð  ð  ð  ð ð ð  ð  ñ „Xð ð ðð ð ñ „Xðð ðð ð ñ „Xðð @Lð
ð 
ð 
ð 
ð 
ðð ð ð ðð ð ð ð"/ð /ð /ð /ð /ð /r   r>   )r   r   )r   r   ) Ú
__future__r   r-   ÚsysÚdataclassesr   Útypingr   r   r   r   Úweakrefr	   Ú_core._eventloopr   Úversion_infor   Útyping_extensionsr   r   r   r   r   r   r   r*   r    r#   ÚEnumr,   r1   r>   r   r   r   ú<module>rn      s1  ðØ "Ð "Ð "Ð "Ð "Ð "Ð "à €€€Ø 
€
€
€
Ø !Ð !Ð !Ð !Ð !Ð !Ø 2Ð 2Ð 2Ð 2Ð 2Ð 2Ð 2Ð 2Ð 2Ð 2Ð 2Ð 2Ø %Ð %Ð %Ð %Ð %Ð %à *Ð *Ð *Ð *Ð *Ð *àÔ�vÒÐØÐÐÐÐÐÐà)Ð)Ð)Ð)Ð)Ð)à€GˆC�L„L€Ø€GˆC�L„L€ð&ð &ð &ð &ð 	3ð 	3ð 	3ð 	3ð6ð 6ð 6ð 6ð *ð *ð *ð *ð
 5FÐ4EÑ4GÔ4G€	Ð GÐ GÐ GÑ GØ,.€Ð .Ð .Ð .Ñ .ð €�$ÐÑÔðð ð ð ð ñ ô ñ Ôðð
ð ð ð ð �$”)ñ ô ð ðð ð ð ð �'˜!”*ñ ô ð ðR/ð R/ð R/ð R/ð R/ˆW�QŒZñ R/ô R/ð R/ð R/ð R/r   