+
    –°³j­  ã                   óþ   € ^ RI t ^ RIt^ RIHt ^ RIHt ^ RIHtHt ^ RI	t	^RI
Ht ^RIHt ^RIHt ^RIHtHt R	t^t ! R
 R]4      t ! R R]4      t ! R R]4      t ! R R]4      t ! R R4      tRR R lltR# )é    N)Údeque)ÚIterator)ÚLiteralÚ	TypedDict)Úbuild_hf_headers)Úhf_raise_for_status)Ú	SSEClient)ÚApiGetReloadEventSourceDataÚApiGetReloadRequestiÏ  c                   ó,   a € ] tR t^"t o V 3R ltRtV tR# )ÚMultiReplicaStreamWarningc                ó@   <€ V ^8„  d   Qh/ S[ R,          ;R&   S[;R&   # )é   ÚwarningÚkindÚmessage©r   Ústr)ÚformatÚ__classdict__s   "€Úc/home/luca/screen-checking/.venv/lib/python3.14/site-packages/huggingface_hub/_hot_reload/client.pyÚ__annotate__Ú&MultiReplicaStreamWarning.__annotate__"   s   ø‡ ‚ Ù
�)Õ
Ññ á�Lò ó    © N©Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__Ú__annotate_func__Ú__static_attributes__Ú__classdictcell__©r   s   @r   r   r   "   ó   ø‡ ‡ „ r   r   c                   ó,   a € ] tR t^'t o V 3R ltRtV tR# )ÚMultiReplicaStreamEventc                ó@   <€ V ^8„  d   Qh/ S[ R,          ;R&   S[;R&   # )r   Úeventr   )r   r
   )r   r   s   "€r   r   Ú$MultiReplicaStreamEvent.__annotate__'   s    ø‡ ‚ Ù
�'Õ
Ññ á&Ñ&ò r   r   Nr   r$   s   @r   r'   r'   '   r%   r   r'   c                   ó,   a € ] tR t^,t o V 3R ltRtV tR# )ÚMultiReplicaStreamReplicaHashc                ó@   <€ V ^8„  d   Qh/ S[ R,          ;R&   S[;R&   # )r   ÚreplicaHashr   Úhashr   )r   r   s   "€r   r   Ú*MultiReplicaStreamReplicaHash.__annotate__,   s   ø‡ ‚ Ù
�-Õ
 Ñ ñ á
�Iò r   r   Nr   r$   s   @r   r,   r,   ,   r%   r   r,   c                   ó,   a € ] tR t^1t o V 3R ltRtV tR# )ÚMultiReplicaStreamFullMatchc                ó4   <€ V ^8„  d   Qh/ S[ R,          ;R&   # )r   Ú	fullMatchr   )r   )r   r   s   "€r   r   Ú(MultiReplicaStreamFullMatch.__annotate__1   s   ø‡ ‚ Ù
�+Õ
Ñò r   r   Nr   r$   s   @r   r2   r2   1   r%   r   r2   c                   óD   a € ] tR t^5t o V 3R lR ltV 3R lR ltRtV tR# )ÚReloadClientc          	      ó@   <€ V ^8„  d   QhRS[ RS[ RS[ RS[ R,          /# )r   ÚhostÚ	subdomainÚreplica_hashÚtokenN)r   )r   r   s   "€r   r   ÚReloadClient.__annotate__6   s9   ø€ ÷ 
ñ 
ñ ð
ñ ð	
ñ
 ð
ñ �T�zñ
r   c               ó¨   € VP                  W" R \         24      pW0n        \        P                  ! V RV 2\        VR7      \        R7      V n        R# )z--z/--replicas/+)r<   )Úbase_urlÚheadersÚtimeoutN)ÚreplaceÚHOT_RELOADING_PORTr;   ÚhttpxÚClientr   ÚCLIENT_TIMEOUTÚclient)Úselfr9   r:   r;   r<   Ú	base_hosts   &$$$$ r   Ú__init__ÚReloadClient.__init__6   sN   € ð —L‘L ¨k¸Ô<NÐ;OÐ,PÓQˆ	Ø(ÔÜ—l’lØ!�{ -°¨~Ð>Ü$¨5Ô1Ü"ô
ˆŽr   c                óF   <€ V ^8„  d   QhRS[ RS[S[,          S[,          /# )r   Ú	reload_idÚreturn)r   r   r
   Úint)r   r   s   "€r   r   r=   F   s'   ø€ ÷ 	ñ 	¡Cð 	©HÑ5PÕ,QÑTWÕ,Wñ 	r   c              #  óÖ  "  € \        VR 7      pV P                  P                  RRVR7      ;_uu_ 4       pVP                  ^È8w  d   VP                  uuRRR4       # \	        V4       \        VP                  4       4      P                  4        F8  pVP                  R8X  g   K  \        P                  ! VP                  4      x € K:  	  RRR4       R#   + '       g   i     R# ; i5i))ÚreloadIdÚPOSTz/get-reload)ÚjsonNr   )r   rG   ÚstreamÚstatus_coder   r	   Ú
iter_bytesÚeventsr)   rS   ÚloadsÚdata)rH   rM   ÚreqÚresr)   s   &&   r   Ú
get_reloadÚReloadClient.get_reloadF   sª   é € Ü!¨9Ô5ˆØ�[‰[×Ñ ¨¸CÐ×@Ô@ÀCØ�‰ #Ô%Ø—‘÷ AÒ@ô   Ô$Ü" 3§>¡>Ó#3Ó4×;Ñ;Ö=�Ø—;‘; )Ö+ÜŸ*š* U§Z¡ZÓ0Ô0ñ >÷	 Añ ÷ AÖ@ñ üs/   ‚3C)µCÁC)ÁACÂ%&CÃ
C)ÃC&	Ã 	C))rG   r;   N)r   r   r   r    rJ   r\   r"   r#   r$   s   @r   r7   r7   5   s   ø‡ € ÷
ð 
÷ 	ö 	r   r7   c                óè   € V ^8„  d   QhR\         R\         R\         R\        \         ,          R\         R,          R\        R\        \        \
        ,          \        ,          \        ,          ,          /# )	r   Ú
commit_shar9   r:   Úreplica_hashesr<   NÚmax_retriesrN   )r   ÚlistrO   r   r   r'   r,   r2   )r   s   "r   r   r   R   sp   € ÷ 0(ñ 0(Üð0(ä
ð0(ô ð0(ô œ•Ið	0(ô
 ��:ð0(ô ð0(ô ÜÔ 7Õ7Ô:WÕWÔZuÕuõñ0(r   c           
   #   ó2  "  € V Uu. uF  p\        VVVVR 7      NK  	  pp/ p\        V4       EF]  w  rš\        V4      ^8”  d   RRRV
P                  /x € ^ p\	        V
P                  V 4      ;p\        4      '       dc   V^,           ;qµ8”  d   \        R4      hT;pR9  d   \        RV: R24      hV^Ì8X  d   RMRpRR	R
RV R2/x € \        P                  ! ^4       K‰  Rp\        4       p\        V4       Ft  w  ppV	^ 8X  d   VVV&   M9T;'       d    VP                  V4      V8H  ;p'       d   VP                  V4       KL  V'       d   RRRVP                  4       /x € K   RRRV/x € Kv  	  V	^ 8”  g   EKL  V'       g   EKW  RR/x € EK`  	  R# u upi 5i))r9   r:   r;   r<   r   r.   r/   zToo many retries reachedzUnexpected status_code=z on `ReloadClient.get_reload`rQ   Úreplicar   r   zRetrying on unexpected z
 not foundTr)   r4   N)éÈ   éÌ   )r7   Ú	enumerateÚlenr;   Ú
isinstancer\   rO   Ú	ExceptionÚtimeÚsleepr   ÚgetÚappendÚpopleft)r_   r9   r:   r`   r<   ra   r/   ÚclientsÚfirst_client_eventsÚclient_indexrG   ÚretriesrW   rU   ÚsubjectÚ
full_matchÚreplayÚevent_indexr)   s   &&&&&&             r   Úmulti_replica_reload_eventsrx   R   s¹  é € ñ" #óñ #ˆDô 	ØØØØ÷		
ñ #ð ð ð CEÐÜ )¨'× 2ÑˆÜˆw‹<˜!ÔØ˜=¨&°&×2EÑ2EÐFÒFàˆÜ F×$5Ñ$5°jÓ$AÐA˜&ÄC×HÒHØ" Q�;Ð&�Ô5ÜÐ :Ó;Ð;Ø%Ð%�¨jÔ8ÜÐ":¨k©^Ð;XÐ YÓZÐZØ$/°3Ô$6‘j¸IˆGØ˜9 iÐ3JÈ7È)ÐS]Ð1^Ð_Ò_Ü�JŠJ�qŽMàˆ
Ü5:³WˆÜ"+¨FÖ"3ÑˆK˜Ø˜qÔ Ø38Ð# KÒ0Ø)×[Ð[Ð.A×.EÑ.EÀkÓ.RÐV[Ñ.[Ð[�Ö[Ø—‘˜eÔ$ÙßØ˜w¨°·±Ó1AÐBÔBØ˜7 G¨UÐ3Ô3ñ #4ð ˜!×§
¢
Ø˜;Ð'Õ'ó7 !3ùòùs.   ‚F‡FŸC4FÄFÄ1FÅ(FÅ:FÆF)é
   )rS   rk   Úcollectionsr   Úcollections.abcr   Útypingr   r   rD   Úutils._headersr   Úutils._httpr   Ú
sse_clientr	   Útypesr
   r   rC   rF   r   r'   r,   r2   r7   rx   r   r   r   Ú<module>r�      sv   ðó  Û Ý Ý $ß %ã å -Ý -Ý !ß Cð Ð Ø€ô 	ô ô
'˜iô 'ô
 Iô ô
 )ô ÷ñ ÷:0(ñ 0(r   