j RUddlZddlZddlmZmZmZmZmZddlm Z ddl m Z ddl m cmZddlmZgZeeed<ejeaedZe dZd eeeffd Zd eeeffd Z dd eded eeeefgeeefffdZdS)N)AnyCallableDictListTypeVar) ParamSpec)uuid4)DCP_LOGGER_NAME__all___T_Preturnci}|dd}|dd}|dd}|dd}|s|p|x}rt|dd}|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)getgetattrstrr int __class____name__)argskwargsmsg_dictrrrr serializers TC:\Projects\Historical\venv\Lib\site-packages\torch/distributed/checkpoint/logger.py_msg_dict_from_dcp_method_argsr sHZZ 0$77NZZ 0$77NjjD))GJJ55M CN,LnLjC OTBB ,7M] _ 577;''HVG%3%=%F!"G%3%=%F!"9%/8 Ocnt|i|}|tj|g|Ri||S)N)r update c10d_logger _get_msg_dict) func_namerrrs rr%r%7sF-t>v>>H OOK-iI$III&IIJJJ Or!Flog_exceptionswrapper_kwargsc Jdtttfffd }|S)zKThis method decorator logs the start, end, and exception of wrapped events.funcctjdtjdtjdt ffd }|S)Nrrrctjg|Rii |}d|d<tj}||d<|d<t| |i|}nP#t $rC}r;d|d<||d<tj|d<t|d}~wwxYwd|d<tj}tj|d<||z |d<t||S) Nstarteventtimer' exceptionerrorend times_spent)r%rr/time_ns _dcp_loggerdebug BaseExceptionr1) rrrt0resultr1t1r*r'r(s rwrapperz6_dcp_method_logger..decorator..wrapperDsH$  $(D>(DV(DH !(HW B!HV )7H% &   h ' ' ' t.v..    !0(3HW%+0 HW%'+|~~HV$%%h///  !&HW B#|~~HV &(2gH] #   h ' ' 'MsA!! B.+>B))B.) functoolswrapsr rrr )r*r;r'r(s` r decoratorz%_dcp_method_logger..decoratorCsb    27 bi B          @r!)rr r )r'r(r>s`` r_dcp_method_loggerr?>s@ "R("""""""H r!)F)r<r/typingrrrrrtyping_extensionsrrr torch.distributed.c10d_logger distributedr$-torch.distributed.checkpoint.logging_handlersr r r__annotations___get_or_create_loggerr5r r r r%boolr?r!rrIs 55555555555555''''''333333333IIIIIIc0k/@@  WT]]Yt__tCH~Dc3h!)))47) xB (2r6"223))))))r!