a h @sUddlZddlZddlZddlmZmZmZddlmZddl m Z ddl m m Z ddlmZeZgZeeed<e eaedZedZeeefd d d Zeeefd d d ZdeeeeeefgeeeffdddZedddZ dS)N)AnyCallableTypeVar) ParamSpec)uuid4)DCP_LOGGER_NAME__all___T_P)returncOsi}|dd}|dd}|dd}|dd}|sP|p>|}rPt|dd}|dur`t|n||d<ttj|d<|r|jj|d<|r|jj|d<|r|jj|d<|S)z0 Extracts log data from dcp method args storage_writerNstorage_readerplanner checkpoint_iduuid)getgetattrstrrint __class____name__)argskwargsmsg_dictr r rr serializerrQ/var/www/auris/lib/python3.9/site-packages/torch/distributed/checkpoint/logger.py_msg_dict_from_dcp_method_argss"        rcOs0t|i|}|tj|g|Ri||S)N)rupdate c10d_logger _get_msg_dict) func_namerrrrrrr ;sr F)log_exceptionswrapper_kwargsr c s tttfdfdd }|S)zKThis method decorator logs the start, end, and exception of wrapped events.funccs,ttjtjtdfdd }|S)N)rrr c stjg|Rii|}d|d<t}||d<|d<t|z|i|}WnRty}z:rd|d<||d<t|d<t|WYd}~n d}~00d|d<t}t|d<|||d<t||S) Nstarteventtimer" exceptionerrorendZ times_spent)r rr(time_ns _dcp_loggerdebug BaseExceptionr*)rrrt0resultr*t1)r%r"r#rrwrapperHs6        z6_dcp_method_logger..decorator..wrapper) functoolswrapsr rrr )r%r3r"r#r$r decoratorGs z%_dcp_method_logger..decorator)rr r )r"r#r7rr6r_dcp_method_loggerBs$r8)rankcCsJttjt}|tjtd|d}||t|dS)N[z6] %(asctime)s - %(name)s - %(levelname)s - %(message)s)loggersetLevelloggingINFO StreamHandler Formatter setFormatter addHandler)r9ch formatterrrr _init_loggerns    rE)F)!r4r=r(typingrrrZtyping_extensionsrrrZtorch.distributed.c10d_loggerZ distributedrZ-torch.distributed.checkpoint.logging_handlersr getLoggerr;rlistr__annotations__Z_get_or_create_loggerr-r r dictrr boolr8rrErrrrs(     " ,