+
    IV-j¯  ã                   óR   € R t ^ RIHt ^ RIHt ^RIHt RR./tR.t	 ! R R4      t
R# )	z,
IO/concurrency helpers for `tqdm.contrib`.
)Údeque)ÚThreadPoolExecutor)Útqdmzgithub.com/Ú	casperdclÚ
MonoWorkerc                   ó0   a € ] tR t^t o RtR tR tRtV tR# )r   zw
Supports one running task and one waiting task.
The waiting task is the most recent submitted (others are discarded).
c                óJ   € \        ^R7      V n        \        . ^4      V n        R# )é   )Úmax_workersN)r   Úpoolr   Úfutures)Úselfs   &Új/Volumes/fast/ai/experiments/ui-tars-smoke/.venv/lib/python3.14/site-packages/tqdm/contrib/utils_worker.pyÚ__init__ÚMonoWorker.__init__   s   € Ü&°1Ô5ˆŒ	Ü˜R “|ˆŽó    c                óö  € V P                   p\        V4      VP                  8X  di   VP                  4       pVP	                  4       '       gC   \        V4      '       d!   VP                  4       pVP                  4        VP                  V4        V P                  P                  ! V.VO5/ VB pVP                  V4       V#   \         d+   p\        P                  ! \        T4      4        Rp?R# Rp?ii ; i)z;`func(*args, **kwargs)` may replace currently waiting task.N)r   ÚlenÚmaxlenÚpopleftÚdoneÚpopÚcancelÚ
appendleftr   ÚsubmitÚappendÚ	ExceptionÚ	tqdm_autoÚwriteÚstr)r   ÚfuncÚargsÚkwargsr   ÚrunningÚwaitingÚes   &&*,    r   r   ÚMonoWorker.submit   s¹   € à—,‘,ˆÜˆw‹<˜7Ÿ>™>Ô)Ø—o‘oÓ'ˆGØ—<‘<—>’>Ü�w—<’<Ø%Ÿk™k›m�GØ—N‘NÔ$Ø×"Ñ" 7Ô+ð	Ø—i‘i×&Ò& tÐ=¨dÒ=°fÑ=ˆGð �N‰N˜7Ô#ØˆNøô	 ô 	$Ü�OŠOœC ›F×#Ò#ûð	$ús   Â C ÃC8ÃC3Ã3C8)r   r   N)	Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__Ú__doc__r   r   Ú__static_attributes__Ú__classdictcell__)Ú__classdict__s   @r   r   r      s   ø‡ € ñò$÷ð r   N)r+   Úcollectionsr   Úconcurrent.futuresr   Úautor   r   Ú
__author__Ú__all__r   © r   r   Ú<module>r5      s2   ðñõ Ý 1å $à˜k˜]Ð+€
Øˆ.€÷ó r   