+
    Q?j$                       ^ RI Ht ^ RIt^ RIt^RIHtHtHt  ^ RIt ^ RIt ^ RItR R lt ! R R4      t ! R R	4      t ! R
 R4      t ! R R4      t ! R R4      t ! R R4      t ! R R4      t ! R R4      t ! R R4      t ! R R4      tR#   ]	]
3 d    Rt Li ; i  ]	 d    Rt Li ; i  ]	 d    Rt Li ; i)    )annotationsN)ExceptionMappingPoolTimeoutmap_exceptionsc                   V ^8  d   QhRR/# )   returnstr )formats   "ڃ/home/vela/workspace/domain/tn-silver/web/tn-site/.runtime/imagegen-venv/lib/python3.14/site-packages/httpcore2/_synchronization.py__annotate__r      s      s     c                     \         f   Rp M\         P                  ! 4       p V R9  d   \        R4      hV R8X  d   \        f   \        R4      hV R8X  d   \        f   \        R4      hV # )Nasynciotrioz/Running under an unsupported async environment.zBRunning with asyncio requires installation of 'httpcore[asyncio]'.z<Running with trio requires installation of 'httpcore[trio]'.)r   r   )sniffiocurrent_async_libraryRuntimeErroranyior   )environments    r   r   r      sg     335--LMMiEM_``fYZZr   c                  N    ] tR t^/tRtR R ltR R ltR R ltRR	 R
 lltRt	R# )	AsyncLock
This is a standard lock.

In the sync case `Lock` provides thread locking.
In the async case `AsyncLock` provides async locking.
c                   V ^8  d   QhRR/# r   r	   Noner   )r   s   "r   r   AsyncLock.__annotate__7         $ r   c                	    R V n         R#  N_backendselfs   &r   __init__AsyncLock.__init__7   	    r   c                   V ^8  d   QhRR/# r   r   )r   s   "r   r   r   :   s     	= 	=t 	=r   c                    \        4       V n        V P                  R8X  d   \        P                  ! 4       V n        R# V P                  R8X  d   \
        P                  ! RR7      V n        R# R# )f
Detect if we're running under 'asyncio' or 'trio' and create
a lock with the correct implementation.
r   r   T)fast_acquireN)r   r$   r   Lock
_trio_lockr   _anyio_lockr%   s   &r   setupAsyncLock.setup:   sI    
 ./==F""iikDO]]i'$zzt<D (r   c                   V ^8  d   QhRR/# )r   r	   r   r   )r   s   "r   r   r   E   s     	 	) 	r   c                	*  "   V P                   '       g   V P                  4        V P                   R 8X  d%   V P                  P                  4       G Rj  xL
  V # V P                   R8X  d#   V P                  P                  4       G Rj  xL
  V #  L; L5ir   Nr   )r$   r1   r/   acquirer0   r%   s   &r   
__aenter__AsyncLock.__aenter__E   ss     }}}JJL==F"//))+++  ]]i'""**,,,	 ,,s$   ABB4BB	BBNc               (    V ^8  d   QhRRRRRRRR/# 	r   exc_typeztype[BaseException] | None	exc_valuezBaseException | None	tracebackztypes.TracebackType | Noner	   r   r   )r   s   "r   r   r   P   s2     	' 	',	' (	' .		'
 
	'r   c                	   "   V P                   R 8X  d   V P                  P                  4        R# V P                   R8X  d   V P                  P                  4        R# R# 5ir   r   N)r$   r/   releaser0   r&   r;   r<   r=   s   &&&&r   	__aexit__AsyncLock.__aexit__P   sF      ==F"OO##%]]i'$$& (   AA)r0   r$   r/   NNN)
__name__
__module____qualname____firstlineno____doc__r'   r1   r7   rB   __static_attributes__r   r   r   r   r   /   s     	=		' 	'r   r   c                  6    ] tR t^\tRtR R ltRR R lltRtR# )	AsyncThreadLock
This is a threading-only lock for no-I/O contexts.

In the sync case `ThreadLock` provides thread locking.
In the async case `AsyncThreadLock` is a no-op.
c                   V ^8  d   QhRR/# )r   r	   rM   r   )r   s   "r   r   AsyncThreadLock.__annotate__d   s      ? r   c                	    V # Nr   r%   s   &r   	__enter__AsyncThreadLock.__enter__d       r   Nc               (    V ^8  d   QhRRRRRRRR/# r:   r   )r   s   "r   r   rP   g   2      , ( .	
 
r   c                	    R # rR   r   rA   s   &&&&r   __exit__AsyncThreadLock.__exit__g        	r   r   rE   )rF   rG   rH   rI   rJ   rS   rY   rK   r   r   r   rM   rM   \   s     r   rM   c                  J    ] tR t^ptR R ltR R ltR R ltRR R	 lltR
tR# )
AsyncEventc                   V ^8  d   QhRR/# r   r   )r   s   "r   r   AsyncEvent.__annotate__q   r   r   c                	    R V n         R# r!   r#   r%   s   &r   r'   AsyncEvent.__init__q   r)   r   c                   V ^8  d   QhRR/# r   r   )r   s   "r   r   r_   t   s     	. 	.t 	.r   c                    \        4       V n        V P                  R8X  d   \        P                  ! 4       V n        R# V P                  R8X  d   \
        P                  ! 4       V n        R# R# )r,   r   r   N)r   r$   r   Event_trio_eventr   _anyio_eventr%   s   &r   r1   AsyncEvent.setupt   sG    
 ./==F"#zz|D]]i' %D (r   c                   V ^8  d   QhRR/# r   r   )r   s   "r   r   r_      s     $ $T $r   c                	    V P                   '       g   V P                  4        V P                   R 8X  d   V P                  P                  4        R# V P                   R8X  d   V P                  P                  4        R# R# r?   )r$   r1   re   setrf   r%   s   &r   rj   AsyncEvent.set   sU    }}}JJL==F"  "]]i'!!# (r   Nc                    V ^8  d   QhRRRR/# r   timeoutzfloat | Noner	   r   r   )r   s   "r   r   r_      s     3 3, 3$ 3r   c           	     	<  "   V P                   '       g   V P                  4        V P                   R 8X  d   \        P                  \        /pVf   \        R4      MTp\        V4      ;_uu_ 4        \        P                  ! V4      ;_uu_ 4        V P                  P                  4       G Rj  xL
  RRR4       RRR4       R# V P                   R8X  dt   \        \        /p\        V4      ;_uu_ 4        \        P                  ! V4      ;_uu_ 4        V P                  P                  4       G Rj  xL
  RRR4       RRR4       R# R#  L  + '       g   i     L; i  + '       g   i     R# ; i LA  + '       g   i     LG; i  + '       g   i     R# ; i5i)r   Ninfr   )r$   r1   r   TooSlowErrorr   floatr   
fail_afterre   waitTimeoutErrorr   rf   )r&   rn   trio_exc_maptimeout_or_infanyio_exc_maps   &&   r   rt   AsyncEvent.wait   s    }}}JJL==F".2.?.?-ML-4_U5\'N--__^44**//111 5 .- ]]i'/;[.IM..%%g..++00222 / /. ( 2 54 .-- 3 /. /..s   A.F0EE	-E
.E	2E::F4FE5	1E32E5	6F>F
E	EEE0	*	F3E5	5F FF		F)rf   r$   re   rR   )	rF   rG   rH   rI   r'   r1   rj   rt   rK   r   r   r   r]   r]   p   s    	.$3 3r   r]   c                  F    ] tR t^tR R ltR R ltR R ltR R ltR	tR
# )AsyncSemaphorec                    V ^8  d   QhRRRR/# r   boundintr	   r   r   )r   s   "r   r   AsyncSemaphore.__annotate__   s      c d r   c                	     Wn         R V n        R# r!   )_boundr$   r&   r~   s   &&r   r'   AsyncSemaphore.__init__   s    r   c                   V ^8  d   QhRR/# r   r   )r   s   "r   r   r      s     	y 	yt 	yr   c                6   \        4       V n        V P                  R8X  d4   \        P                  ! V P                  V P                  R7      V n        R# V P                  R8X  d5   \        P                  ! V P                  V P                  RR7      V n        R# R# )zk
Detect if we're running under 'asyncio' or 'trio' and create
a semaphore with the correct implementation.
r   )initial_value	max_valuer   T)r   r   r-   N)r   r$   r   	Semaphorer   _trio_semaphorer   _anyio_semaphorer%   s   &r   r1   AsyncSemaphore.setup   sj    
 ./==F"#'>>W[WbWb#cD ]]i'$)OO$++Y]YdYdsw$xD! (r   c                   V ^8  d   QhRR/# r   r   )r   s   "r   r   r      s     2 2t 2r   c                	.  "   V P                   '       g   V P                  4        V P                   R 8X  d%   V P                  P                  4       G Rj  xL
  R# V P                   R8X  d%   V P                  P                  4       G Rj  xL
  R# R#  L= L
5ir5   )r$   r1   r   r6   r   r%   s   &r   r6   AsyncSemaphore.acquire   sl     }}}JJL==F"&&..000]]i'''//111 ( 11s$   ABB4BB		BBc                   V ^8  d   QhRR/# r   r   )r   s   "r   r   r      s     , ,t ,r   c                	   "   V P                   R 8X  d   V P                  P                  4        R# V P                   R8X  d   V P                  P                  4        R# R# 5ir?   )r$   r   r@   r   r%   s   &r   r@   AsyncSemaphore.release   sF     ==F"  ((*]]i'!!))+ (rD   )r   r$   r   r   N)	rF   rG   rH   rI   r'   r1   r6   r@   rK   r   r   r   r{   r{      s    	y2, ,r   r{   c                  >    ] tR t^tR R ltR R ltR	R R lltRtR# )
AsyncShieldCancellationc                   V ^8  d   QhRR/# r   r   )r   s   "r   r   $AsyncShieldCancellation.__annotate__   s     
@ 
@$ 
@r   c                    \        4       V n        V P                  R8X  d   \        P                  ! RR7      V n        R# V P                  R8X  d   \
        P                  ! RR7      V n        R# R# )zp
Detect if we're running under 'asyncio' or 'trio' and create
a shielded scope with the correct implementation.
r   T)shieldr   N)r   r$   r   CancelScope_trio_shieldr   _anyio_shieldr%   s   &r   r'    AsyncShieldCancellation.__init__   sQ    
 ./==F" $ 0 0 =D]]i'!&!2!2$!?D (r   c                   V ^8  d   QhRR/# )r   r	   r   r   )r   s   "r   r   r      s      2 r   c                	    V P                   R 8X  d   V P                  P                  4        V # V P                   R8X  d   V P                  P                  4        V # )r   r   )r$   r   rS   r   r%   s   &r   rS   !AsyncShieldCancellation.__enter__   sL    ==F"'')  ]]i'((*r   Nc               (    V ^8  d   QhRRRRRRRR/# r:   r   )r   s   "r   r   r      s8     	H 	H,	H (	H .		H
 
	Hr   c                	    V P                   R 8X  d   V P                  P                  WV4       R# V P                   R8X  d   V P                  P                  WV4       R# R# r?   )r$   r   rY   r   rA   s   &&&&r   rY    AsyncShieldCancellation.__exit__   sM     ==F"&&xIF]]i'''YG (r   )r   r$   r   rE   )rF   rG   rH   rI   r'   rS   rY   rK   r   r   r   r   r      s    
@	H 	Hr   r   c                  B    ] tR t^tRtR R ltR R ltR
R R lltR	tR# )r.   r   c                   V ^8  d   QhRR/# r   r   )r   s   "r   r   Lock.__annotate__   s     & &$ &r   c                	:    \         P                  ! 4       V n        R # rR   )	threadingr.   _lockr%   s   &r   r'   Lock.__init__   s    ^^%
r   c                   V ^8  d   QhRR/# )r   r	   r.   r   )r   s   "r   r   r      s      4 r   c                	:    V P                   P                  4        V # rR   r   r6   r%   s   &r   rS   Lock.__enter__       

r   Nc               (    V ^8  d   QhRRRRRRRR/# r:   r   )r   s   "r   r   r      2      , ( .	
 
r   c                	:    V P                   P                  4        R # rR   r   r@   rA   s   &&&&r   rY   Lock.__exit__        	

r   r   rE   	rF   rG   rH   rI   rJ   r'   rS   rY   rK   r   r   r   r.   r.      s    & r   r.   c                  B    ] tR t^tRtR R ltR R ltR
R R lltR	tR# )
ThreadLockrN   c                   V ^8  d   QhRR/# r   r   )r   s   "r   r   ThreadLock.__annotate__  s     ' '$ 'r   c                	:    \         P                  ! 4       V n        R # rR   )r   RLockr   r%   s   &r   r'   ThreadLock.__init__  s    __&
r   c                   V ^8  d   QhRR/# )r   r	   r   r   )r   s   "r   r   r     s      : r   c                	:    V P                   P                  4        V # rR   r   r%   s   &r   rS   ThreadLock.__enter__  r   r   Nc               (    V ^8  d   QhRRRRRRRR/# r:   r   )r   s   "r   r   r   
  r   r   c                	:    V P                   P                  4        R # rR   r   rA   s   &&&&r   rY   ThreadLock.__exit__
  r   r   r   rE   r   r   r   r   r   r      s    ' r   r   c                  >    ] tR tRtR R ltR R ltR
R R lltR	tR# )rd   i  c                   V ^8  d   QhRR/# r   r   )r   s   "r   r   Event.__annotate__  s     ( ($ (r   c                	:    \         P                  ! 4       V n        R # rR   )r   rd   _eventr%   s   &r   r'   Event.__init__  s    oo'r   c                   V ^8  d   QhRR/# r   r   )r   s   "r   r   r     s      T r   c                	:    V P                   P                  4        R # rR   )r   rj   r%   s   &r   rj   	Event.set  s    r   Nc                    V ^8  d   QhRRRR/# rm   r   )r   s   "r   r   r     s        L  D  r   c                	    V\        R 4      8X  d   RpV P                  P                  VR7      '       g   \        4       hR# )rp   N)rn   )rr   r   rt   r   )r&   rn   s   &&r   rt   
Event.wait  s8    eEl"G{{00- 1r   )r   rR   )rF   rG   rH   rI   r'   rj   rt   rK   r   r   r   rd   rd     s    (   r   rd   c                  :    ] tR tRtR R ltR R ltR R ltRtR	# )
r   i!  c                    V ^8  d   QhRRRR/# r}   r   )r   s   "r   r   Semaphore.__annotate__"  s     ; ;c ;d ;r   c                	>    \         P                  ! VR 7      V n        R# ))valueN)r   r   
_semaphorer   s   &&r   r'   Semaphore.__init__"  s    #--E:r   c                   V ^8  d   QhRR/# r   r   )r   s   "r   r   r   %       " " "r   c                	:    V P                   P                  4        R # rR   )r   r6   r%   s   &r   r6   Semaphore.acquire%      !r   c                   V ^8  d   QhRR/# r   r   )r   s   "r   r   r   (  r   r   c                	:    V P                   P                  4        R # rR   )r   r@   r%   s   &r   r@   Semaphore.release(  r   r   )r   N)rF   rG   rH   rI   r'   r6   r@   rK   r   r   r   r   r   !  s    ;"" "r   r   c                  2    ] tR tRtR R ltRR R lltRtR# )	ShieldCancellationi,  c                   V ^8  d   QhRR/# )r   r	   r   r   )r   s   "r   r   ShieldCancellation.__annotate__0  s      - r   c                	    V # rR   r   r%   s   &r   rS   ShieldCancellation.__enter__0  rU   r   Nc               (    V ^8  d   QhRRRRRRRR/# r:   r   )r   s   "r   r   r   3  rW   r   c                	    R # rR   r   rA   s   &&&&r   rY   ShieldCancellation.__exit__3  r[   r   r   rE   )rF   rG   rH   rI   rS   rY   rK   r   r   r   r   r   ,  s     r   r   )
__future__r   r   types_exceptionsr   r   r   r   ImportErrorNotImplementedErrorr   r   r   r   rM   r]   r{   r   r.   r   rd   r   r   r   r   r   <module>r      s    "   F F

(*' *'Z (&3 &3R, ,@$H $HT 0 0   " "  	() D
  E
  Gs3   B B% B4 B"!B"%	B10B14	C ?C 