U yh @sUddlZddlZddlmZmZmZmZmZddlm Z ddl m m Z ddl mZgZeeed<e eaedZe dZeeefdd d Zeeefdd d ZdeeeeeefgeeeffdddZdS)N)AnyCallableDictListTypeVar) ParamSpec)DCP_LOGGER_NAME__all___T_P)returncOs`i}|dd}|dd}|dd}|sD|p2|}rDt|dd}|dk rTt|n||d<|S)z0 Extracts log data from dcp method args storage_writerNstorage_reader checkpoint_id)getgetattrstr)argskwargsmsg_dictr rr serializerrU/var/www/html/venv/lib/python3.8/site-packages/torch/distributed/checkpoint/logger.py_msg_dict_from_dcp_method_argss    rcOs"t||}|tj|f||S)N)rupdate c10d_logger _get_msg_dict) func_namerrrrrrr's rF)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 stjf||}d|d<t}||d<t|z||}WnPtk r}z2rd|d<||d<t|d<t|W5d}~XYnXd|d<t}t|d<|||d<t||S)Nstarteventtime exceptionerrorendZ times_spent)r__name__r$time_ns _dcp_loggerdebug Exceptionr&)rrrt0resultr&t1)r!rrrrwrapper4s4       z6_dcp_method_logger..decorator..wrapper) functoolswrapsr rrr )r!r0rrr r decorator3s z%_dcp_method_logger..decorator)rr r )rrr4rr3r_dcp_method_logger.s#r5)F)r1r$typingrrrrrtyping_extensionsrZtorch.distributed.c10d_logger distributedrZ-torch.distributed.checkpoint.logging_handlersrr r__annotations__Z_get_or_create_loggerr*r r rrboolr5rrrrs$