+
    IV-j­  ã                   ón   € ^ RI t ^ RIHtHtHt ^ RIHt ^ RIHt RR.t ! R R]	4      t
 ! R R]4      tR# )	é    N)ÚEventÚThreadÚcurrent_thread)Útime)ÚwarnÚTMonitorÚTqdmSynchronisationWarningc                   ó   € ] tR t^	tRtRtR# )r	   zf
tqdm multi-thread/-process errors which may cause incorrect nesting
but otherwise no adverse effects
© N)Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__Ú__doc__Ú__static_attributes__r   ó    Ú^/Volumes/fast/ai/experiments/ui-tars-smoke/.venv/lib/python3.14/site-packages/tqdm/_monitor.pyr	   r	   	   s   † õr   c                   óL   a € ] tR t^t o Rt/ tR tR tR tR t	R t
R tRtV tR	# )
r   a6  
Monitoring thread for tqdm bars.
Monitors if tqdm bars are taking too much time to display
and readjusts miniters automatically if necessary.

Parameters
----------
tqdm_cls  : class
    tqdm class to use (can be core tqdm or a submodule).
sleep_interval  : float
    Time to sleep between monitoring checks.
c                óh  € \         P                  ! V R R7       RV n        ^ V n        Wn        W n        V P                  P                  R\        4      V n	        V P                  P                  R\        4      ! 4       V n        \        P                  ! V P                  4       V P                  4        R# )Útqdm_monitor)ÚnameTr   r   N)r   Ú__init__ÚdaemonÚwokenÚtqdm_clsÚsleep_intervalÚ_testÚgetr   Ú_timer   Ú
was_killedÚatexitÚregisterÚ_atexit_signalÚstart)Úselfr   r   s   &&&r   r   ÚTMonitor.__init__   ss   € Ü�Š˜ >Õ2ØˆŒØˆŒ
Ø ŒØ,ÔØ—Z‘Z—^‘^ F¬DÓ1ˆŒ
ØŸ*™*Ÿ.™.¨´%Ô8Ó:ˆŒÜ�Š˜×+Ñ+Ô,Ø�
‰
Žr   c                ó:   € V P                   P                  4        R# )z®
Non-joining shutdown signal.
Avoids deadlocks at interpreter exit from other threads, dead forks, etc.
This daemon thread is auto-reaped on shutdown without needing a join.
N)r    Úset©r%   s   &r   r#   ÚTMonitor._atexit_signal*   s   € ð 	�‰×ÑÖr   c                ó’   € V P                   P                  4        V \        4       Jd   V P                  4        V P	                  4       # ©N)r    r(   r   ÚjoinÚreportr)   s   &r   ÚexitÚTMonitor.exit2   s2   € Ø�‰×ÑÔØ”~Ó'Ó'Ø�I‰IŒKØ�{‰{‹}Ðr   c                óœ   € V P                   P                  P                  4        Uu. uF  p\        VR 4      '       g   K  VNK  	  up# u upi )Ústart_t)r   Ú
_instancesÚcopyÚhasattr)r%   Úis   & r   Úget_instancesÚTMonitor.get_instances8   sF   € àŸ=™=×3Ñ3×8Ñ8Ô:ó *Ñ:�aä˜1˜i×(÷ �Ñ:ñ *ð 	*ùò *s   §A	Á A	c                óÒ  € V P                  4       p Wn        V P                  P                  V P                  4       V P                  P                  4       '       d   R# V P                  P                  4       ;_uu_ 4        V P                  4       pV P                  4       pV Fz  pV P                  P                  4       '       d    RRR4       R# VP                  ^8”  d;   WP                  ,
          VP                  8¼  d   ^Vn	        VP                  R R7       ?K|  	  W P                  4       8w  d   \        R\        ^R7       ?RRR4       EKC    + '       g   i     EKU  ; i)TN)Únolock)Ú
stacklevelzOSet changed size during iteration (see https://github.com/tqdm/tqdm/issues/481))r   r   r    Úwaitr   Úis_setr   Úget_lockr7   ÚminitersÚlast_print_tÚmaxintervalÚrefreshr   r	   )r%   Úcur_tÚ	instancesÚinstances   &   r   ÚrunÚTMonitor.run>   s  € Ø—
‘
“ˆØð ŒJà�O‰O× Ñ  ×!4Ñ!4Ô5à�‰×%Ñ%×'Ò'Ùð —‘×'Ñ'×)Õ)ØŸ
™
›�à ×.Ñ.Ó0�	Û )�Hà—‘×-Ñ-×/Ò/Ø÷ *Ñ)ð !×)Ñ)¨AÔ-Ø"×%:Ñ%:Õ:¸x×?SÑ?SÔSð -.˜Ô)à ×(Ñ(°Ð(Ô5â ñ! !*ð" × 2Ñ 2Ó 4Ô4Üð Jä3ÀõCð ÷5 *×)×)Ô)ús   ÂAEÃA7EÅE&	c                ó@   € V P                   P                  4       '       * # r,   )r    r=   r)   s   &r   r.   ÚTMonitor.reportg   s   € Ø—?‘?×)Ñ)Ó+Ô+Ð+r   )r   r   r   r   r    r   N)r   r   r   r   r   r   r   r#   r/   r7   rF   r.   r   Ú__classdictcell__)Ú__classdict__s   @r   r   r      s5   ø‡ € ñð €Eò	òòò*ò'÷R,ð ,r   )r!   Ú	threadingr   r   r   r   Úwarningsr   Ú__all__ÚRuntimeWarningr	   r   r   r   r   Ú<module>rP      s9   ðÛ ß 3Ñ 3Ý Ý àÐ3Ð
4€ô ô ôX,ˆvö X,r   