+
    &jq                        a  R t0 t ^ RIt^ RIt^ RIHt ^ RIHtHt ^ RIH	t	 ^ RI
t
^ RIHt ^ RIHt ^ RIHt . t] ^ k Rt]3R R	 llt]3R
 R llt]! 4       sR R lt]! R4      t]	! R4      tR R ltR R ltR# )    N)Callable)AnyTypeVar)	ParamSpec)_log_handlers)_WaitCounterdefaultc                D    V ^8  d   QhR\         R\        P                  /#    destinationreturn)strloggingLogger)formats   "u/Users/jameslopez/projects/CWCArchive/cwc-podcast/.venv/lib/python3.14/site-packages/torch/distributed/c10d_logger.py__annotate__r      s     
 
s 
gnn 
    c                    \        V 4      w  r\        P                  ! R V 24      pVP                  \        P                  4       \        P
                  ! R4      pVP                  V4       RVn        VP                  V4       V# )zc10d-za%(asctime)s %(filename)s:%(lineno)s %(levelname)s p:%(processName)s t:%(threadName)s: %(message)sF)	_get_logging_handlerr   	getLoggersetLevelDEBUG	FormattersetFormatter	propagate
addHandler)r   logging_handlerlog_handler_namelogger	formatters   &    r   _get_or_create_loggerr#      sv    (<[(I%O'7&89:F
OOGMM"!!kI   +F
o&Mr   c                f    V ^8  d   QhR\         R\        \        P                  \         3,          /# r   )r   tupler   Handler)r   s   "r   r   r   (   s*     + ++
7??C +r   c                 V    \         V ,          p\        V4      P                   R V  2pW3# )-)r   type__name__)r   log_handlerr    s   &  r   r   r   (   s4      ,K{+445Q{mD**r   c                F    V ^8  d   QhR\         \        \        3,          /# )r   r   )dictr   r   )r   s   "r   r   r   5   s      c3h r   c                 z   \         P                  ! 4       '       Ed   VP                  R 4      ;'       g    VP                  R4      pRV  R\         P                  ! VP                  R4      4       R\         P                  ! V4       R\         P
                  ! 4        R\         P
                  ! V4       R\         P                  ! 4        R	\         P                  ! V4       /pVR,          R
8X  dD   \        P                  P                  P                  4       pRP                  R V 4       4      VR&   V# RV  /pV# )groupprocess_group	func_namepg_namepgbackend
world_size
group_sizeglobal_rank
local_ranknccl.c              3   8   "   T F  p\        V4      x  K  	  R # 5i)N)r   ).0vs   & r   	<genexpr> _get_msg_dict.<locals>.<genexpr>C   s     /M1As   nccl_version)distis_initializedget_get_process_group_nameget_backendget_world_sizeget_ranktorchcudar9   versionjoin)r1   argskwargsr/   msg_dictr@   s   &*,   r   _get_msg_dictrO   5   s   

7#BBvzz/'BI;$66vzz$7GHI$**512T0023T0078dmmo.T]]512
 I&( ::??224L'*xx/M/M'MH^$
 O I;
 Or   _T_Pc                t    V ^8  d   QhR\         \        \        3,          R\         \        \        3,          /# r   funcr   r   rQ   rP   )r   s   "r   r   r   O   s,      HRV, "b&1A r   c                 L   a  \         P                  ! S 4      R  V 3R ll4       pV# )c                d    V ^8  d   QhR\         P                  R\         P                  R\        /# r   rL   rM   r   rQ   rL   rM   rP   )r   s   "r   r   '_exception_logger.<locals>.__annotate__Q   s)      rww "))  r   c                     <  S! V / VB #   \          d;   p\        SP                  .T O5/ TB pT TR &   \        P	                  T4       h Rp?ii ; i)errorN)	ExceptionrO   r*   _c10d_loggerdebug)rL   rM   r\   rN   rT   s   *,  r   wrapper"_exception_logger.<locals>.wrapperP   s]    	((( 	$T]]DTDVDH#('HWx(		s    A5AA	functoolswrapsrT   r`   s   f r   _exception_loggerrf   O   s%    __T  Nr   c                t    V ^8  d   QhR\         \        \        3,          R\         \        \        3,          /# rS   rU   )r   s   "r   r   r   ]   s,      xB' HRV,< r   c                 L   a  \         P                  ! S 4      R  V 3R ll4       pV# )c                d    V ^8  d   QhR\         P                  R\         P                  R\        /# rX   rY   )r   s   "r   r   "_time_logger.<locals>.__annotate___   s)      rww "))  r   c                     < \        R SP                   24      P                  4       ;_uu_ 4        S! V / VB pRRR4       V#   + '       g   i     X# ; i)zpytorch.wait_counter.c10d.N)r   r*   guard)rL   rM   func_returnrT   s   *, r   r`   _time_logger.<locals>.wrapper^   sN    6t}}oFGMMOO//K P POs   	AA	rb   re   s   f r   _time_loggerro   ]   s%    __T 
 Nr   c                V    V ^8  d   Qh/ ^ \         9   d   \        \        ,          ;R&   # )r   __all__)__conditional_annotations__listr   )r   s   "r   r   r   
   s        c  r   )rr   rc   r   collections.abcr   typingr   r   typing_extensionsr   rH   torch.distributeddistributedrA   "torch.distributed.logging_handlersr   torch.monitorr   rq   _DEFAULT_DESTINATIONr#   r   r^   rO   rP   rQ   rf   ro   r   )rr   s   @r   <module>r|      sx       $  '    < &     .B 
 ,+ %&, T]t_r   