ó
    Eñiq  ã                   óv  • % S SK r S SKrS SKJr  S SKJrJr  S SKJr  S SK	r	S SK
Jr  S SKJr  S SKJr  / r\\   \S'   Sr\4S	\S
\R,                  4S jjr\4S	\S
\\R2                  \4   4S jjr\" 5       qS
\\\4   4S jr\" S5      r\" S5      rS\\\4   S
\\\4   4S jr S\\\4   S
\\\4   4S jr!g)é    N)ÚCallable)ÚAnyÚTypeVar)Ú	ParamSpec)Ú_log_handlers)Ú_WaitCounterÚ__all__ÚdefaultÚdestinationÚreturnc                 ó  • [        U 5      u  p[        R                  " SU 35      nUR                  [        R                  5        [        R
                  " S5      nUR                  U5        SUl        UR                  U5        U$ )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        ÚZ/home/mande/repo/quber/.venv/lib/python3.13/site-packages/torch/distributed/c10d_logger.pyÚ_get_or_create_loggerr      sv   € Ü(<¸[Ó(IÑ%€OÜ×Ò Ð'7Ð&8Ð9Ó:€FØ
‡O�O”G—M‘MÔ"Ü×!Ò!Økó€Ið × Ñ  Ô+Ø€FÔØ
×Ñ�oÔ&Ø€Mó    c                 óN   • [         U    n[        U5      R                   SU  3nX4$ )NÚ-)r   ÚtypeÚ__name__)r   Úlog_handlerr   s      r   r   r   (   s4   € ô   Ñ,€KÜ˜{Ó+×4Ñ4Ð5°Q°{°mÐDÐØÐ*Ð*r   c           	      ó`  • [         R                  " 5       (       Ga  UR                  S5      =(       d    UR                  S5      nU  [         R                  " UR                  S5      5       [         R                  " U5       [         R
                  " 5        [         R
                  " U5       [         R                  " 5        [         R                  " U5       S.nUS   S:X  aC  [        R                  R                  R                  5       nSR                  S U 5       5      US	'   U$ S
U  0nU$ )NÚgroupÚprocess_groupÚpg)Ú	func_nameÚpg_nameÚbackendÚ
world_sizeÚ
group_sizeÚglobal_rankÚ
local_rankr)   ÚncclÚ.c              3   ó8   #   • U  H  n[        U5      v •  M     g 7f)N)Ústr)Ú.0Úvs     r   Ú	<genexpr>Ú _get_msg_dict.<locals>.<genexpr>C   s   é € Ð/MÂ¸1´°A·°Âùs   ‚Únccl_versionr'   )ÚdistÚis_initializedÚgetÚ_get_process_group_nameÚget_backendÚget_world_sizeÚget_rankÚtorchÚcudar.   ÚversionÚjoin)r'   ÚargsÚkwargsr$   Úmsg_dictr6   s         r   Ú_get_msg_dictrE   5   sû   € Ü×Ò×ÒØ—
‘
˜7Ó#×B v§z¡z°/Ó'Bˆà%˜;Ü×6Ò6°v·z±zÀ$Ó7GÓHÐIÜ×*Ò*¨5Ó1Ð2Ü!×0Ò0Ó2Ð3Ü!×0Ò0°Ó7Ð8Ü"Ÿmšm›oÐ.Ü!Ÿ]š]¨5Ó1Ð2ñ
ˆð �IÑ &Ó(Ü Ÿ:™:Ÿ?™?×2Ñ2Ó4ˆLØ'*§x¡xÑ/MÁÓ/MÓ'MˆH�^Ñ$ð
 €Oð ˜I˜;ð
ˆð €Or   Ú_TÚ_PÚfuncc                 ó–   ^ • [         R                  " T 5      S[        R                  S[        R                  S[
        4U 4S jj5       nU$ )NrB   rC   r   c                  ó¤   >•  T" U 0 UD6$ ! [          a:  n[        TR                  /U Q70 UD6nU US'   [        R	                  U5        e S nAff = f)NÚerror)Ú	ExceptionrE   r!   Ú_c10d_loggerÚdebug)rB   rC   rK   rD   rH   s       €r   ÚwrapperÚ"_exception_logger.<locals>.wrapperP   s]   ø€ ð	Ù˜Ð( Ñ(Ð(øÜó 	Ü$ T§]¡]ÐD°TÒD¸VÑDˆHØ#( 'ˆH�WÑÜ×Ñ˜xÔ(Øûð		ús   ƒ ‹
A•5A
Á
A©Ú	functoolsÚwrapsrG   rB   rC   rF   ©rH   rO   s   ` r   Ú_exception_loggerrU   O   sB   ø€ Ü‡_‚_�TÓð”r—w‘wð ¬"¯)©)ð ¼ö ó ðð €Nr   c                 ó–   ^ • [         R                  " T 5      S[        R                  S[        R                  S[
        4U 4S jj5       nU$ )NrB   rC   r   c                  óš   >• [        STR                   35      R                  5          T" U 0 UD6nS S S 5        U$ ! , (       d  f       W$ = f)Nzpytorch.wait_counter.c10d.)r   r!   Úguard)rB   rC   Úfunc_returnrH   s      €r   rO   Ú_time_logger.<locals>.wrapper^   sK   ø€ äÐ6°t·}±}°oÐFÓG×MÑMÕOÙ Ð/¨Ñ/ˆK÷ PàÐ÷ PÔOàÐús	   ¨	;»
A
rQ   rT   s   ` r   Ú_time_loggerr[   ]   sB   ø€ Ü‡_‚_�TÓð”r—w‘wð ¬"¯)©)ð ¼ö ó ðð
 €Nr   )"rR   r   Úcollections.abcr   Útypingr   r   Útyping_extensionsr   r>   Útorch.distributedÚdistributedr7   Ú"torch.distributed.logging_handlersr   Útorch.monitorr   r	   Úlistr1   Ú__annotations__Ú_DEFAULT_DESTINATIONÚLoggerr   ÚtupleÚHandlerr   rM   ÚdictrE   rF   rG   rU   r[   © r   r   Ú<module>rk      sù   ðô Û Ý $ß Ý 'ã Ý  Ý <Ý &ð €ˆˆc‰Ó à Ð ð .Bñ 
 sð 
ÀgÇnÁnõ 
ð ,ñ+Øð+à
ˆ7�?‰?˜CÐÑ õ+ñ %Ó&€ð°°c¸3°h±ô ñ, ˆTƒ]€Ùˆtƒ_€ð˜H R¨ VÑ,ð °¸"¸b¸&Ñ1Aô ð�x  B Ñ'ð ¨H°R¸°VÑ,<õ r   