
    קg
                        U d dl Z d dlZd dlZd dlmZmZmZmZmZm	Z	 d dl
mZ d dlZd dlmZ d dlmZ g Zee         ed<   dZefdedej        fd	Zefdedeej        ef         fd
Z e            adeeef         fdZ e	d          Z ed          Zdeeef         deeef         fdZdeeef         deeef         fdZdS )    N)AnyCallableDictListTupleTypeVar)	ParamSpec)_log_handlers__all__defaultdestinationreturnc                     t          |           \  }}t          j        d|           }|                    t          j                   t          j        d          }|                    |           d|_        |                    |           |S )Nzc10d-za%(asctime)s %(filename)s:%(lineno)s %(levelname)s p:%(processName)s t:%(threadName)s: %(message)sF)	_get_logging_handlerlogging	getLoggersetLevelDEBUG	FormattersetFormatter	propagate
addHandler)r   logging_handlerlog_handler_namelogger	formatters        Y/var/www/html/ai-engine/env/lib/python3.11/site-packages/torch/distributed/c10d_logger.py_get_or_create_loggerr      s    (<[(I(I%O%9'799::F
OOGM"""!k I   +++F
o&&&M    c                 V    t           |          }t          |          j         d|  }||fS )N-)r
   type__name__)r   log_handlerr   s      r   r   r   '   s9      ,K{++4DD{DD)**r   c           
      d   t          j                    r|                    d          p|                    d          }|  | d| t          j        |                    d                     t          j        |           t          j                     t          j        |           t          j                     t          j        |           d}|d         dk    rEt          j        j	        
                                }d                    d	 |D                       |d
<   n|  | d| d}|S )Ngroupprocess_groupz, pg)	func_nameargspg_namebackend
world_size
group_sizeglobal_rank
local_rankr,   nccl.c              3   4   K   | ]}t          |          V  d S )N)str).0vs     r   	<genexpr>z _get_msg_dict.<locals>.<genexpr>B   s(      /M/M1A/M/M/M/M/M/Mr   nccl_version)r)   r*   )distis_initializedget_get_process_group_nameget_backendget_world_sizeget_ranktorchcudar1   versionjoin)r)   r*   kwargsr&   msg_dictr8   s         r   _get_msg_dictrF   3   s9    


7##Bvzz/'B'B%''v''6vzz$7G7GHHJ*5113!0224!0779"moo/!]5113	
 	
 I&(( :?2244L'*xx/M/M/M/M/M'M'MH^$ &''v''
 
 Or   _T_Pfuncc                      t          j                   dt          j        dt          j        dt
          f fd            }|S )Nr*   rD   r   c                      	  | i |S # t           $ r;}t          j        g| R i |}| |d<   t                              |            d }~ww xY w)Nerror)	ExceptionrF   r#   _c10d_loggerdebug)r*   rD   rL   rE   rI   s       r   wrapperz"_exception_logger.<locals>.wrapperP   s~    	4(((( 	 	 	$T]DTDDDVDDH#(
HWx(((		s    
A6AA	functoolswrapsrH   r*   rD   rG   rI   rP   s   ` r   _exception_loggerrU   O   sV    _Trw ")        Nr   c                      t          j                   dt          j        dt          j        dt
          f fd            }|S )Nr*   rD   r   c                      t          j                    } | i |}t          j                    |z
  }t          j        g| R i |}| d|d<   t                              |           |S )Nns
time_spent)timetime_nsrF   r#   rN   rO   )r*   rD   t1func_returnrY   rE   rI   s         r   rP   z_time_logger.<locals>.wrapper^   s~    \^^dD+F++\^^b(
 @@@@@@$.!2!2!28$$$r   rQ   rT   s   ` r   _time_loggerr^   ]   sV    _T	rw 	") 	 	 	 	 	 	 	 Nr   ) rR   r   rZ   typingr   r   r   r   r   r   typing_extensionsr	   r@   torch.distributeddistributedr9   "torch.distributed.logging_handlersr
   r   r4   __annotations___DEFAULT_DESTINATIONLoggerr   Handlerr   rN   rF   rG   rH   rU   r^    r   r   <module>ri      s          < < < < < < < < < < < < < < < < ' ' ' ' ' '              < < < < < < c      .B 
 
s 
gn 
 
 
 
 ,+ ++
7?C + + + + %$&&c3h    0 WT]]Yt__HRV, "b&1A    xB' HRV,<      r   