o ߗi @sUddlZddlZddlmZmZmZmZmZddlm Z ddl m Z ddl m mZddlmZgZeeed<eeaedZe dZd eeeffd d Zd eeeffd d Z ddeded eeeefgeeefffddZdS)N)AnyCallableDictListTypeVar) ParamSpec)uuid4)DCP_LOGGER_NAME__all___T_PreturncOsi}|dd}|dd}|dd}|dd}|s(|p|}r(t|dd}|dur0t|n||d<ttj|d<|rD|jj|d<|rL|jj|d<|rT|jj|d<|S)z0 Extracts log data from dcp method args storage_writerNstorage_readerplanner checkpoint_iduuid)getgetattrstrrint __class____name__)argskwargsmsg_dictrrrr serializerra/home/ubuntu/transcripts/venv/lib/python3.10/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"7sr"Flog_exceptionswrapper_kwargsc s dtttfffdd }|S)zKThis method decorator logs the start, end, and exception of wrapped events.funccs0tdtjdtjdtffdd }|S)Nrrr c stjg|Rii|}d|d<t}||d<|d<t|z |i|}Wn#tyQ}zrLd|d<||d<t|d<t|d}~wwd|d<t}t|d<|||d<t||S) Nstarteventtimer$ exceptionerrorend times_spent)r"rr)time_ns _dcp_loggerdebug BaseExceptionr+)rrrt0resultr+t1)r&r$r%rrwrapperDs:         z6_dcp_method_logger..decorator..wrapper) functoolswrapsr rrr )r&r5r$r%)r&r decoratorCs$ z%_dcp_method_logger..decorator)rr r )r$r%r9rr8r_dcp_method_logger>s$r:)F)r6r)typingrrrrrtyping_extensionsrrrtorch.distributed.c10d_logger distributedr!-torch.distributed.checkpoint.logging_handlersr r r__annotations___get_or_create_loggerr/r r rr"boolr:rrrrs*     "