U 3þjg— ã@sàUddlZddlZddlmZmZmZmZmZddlm Z ddl m m Z ddl mZgZeeed<e  e¡aedƒZe dƒZeeefdœd d „Zeeefdœd d „Zdeeeeeefgeeeffdœdd„ZdS)éN)ÚAnyÚCallableÚDictÚListÚTypeVar)Ú 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_writerNÚstorage_readerÚ checkpoint_id)ÚgetÚgetattrÚstr)ÚargsÚkwargsÚmsg_dictr rrÚ serializer©rúG/tmp/pip-unpacked-wheel-ttp2cnii/torch/distributed/checkpoint/logger.pyÚ_msg_dict_from_dcp_method_argss    ÿrcOs"t||Ž}| tj|f|Ž¡|S)N)rÚupdateÚ c10d_loggerÚ _get_msg_dict)Ú func_namerrrrrrr's rF)Úlog_exceptionsÚwrapper_kwargsr c s tttfdœ‡‡fdd„ }|S)zKThis method decorator logs the start, end, and exception of wrapped events.©Úfunccs,t ˆ¡tjtjtdœ‡‡‡fdd„ ƒ}|S)N)rrr c sÎtˆjf|žˆ|–Ž}d|d<t ¡}||d<t |¡zˆ||Ž}WnPtk r–}z2ˆr„d|d<|›|d<t ¡|d<t |¡‚W5d}~XYnXd|d<t ¡}t ¡|d<|||d<t |¡|S)NÚstartÚeventÚtimeÚ exceptionÚerrorÚendZ times_spent)rÚ__name__r$Útime_nsÚ _dcp_loggerÚdebugÚ Exceptionr&)rrrÚt0Úresultr&Út1)r!rrrrÚwrapper4s4ÿÿÿ       z6_dcp_method_logger..decorator..wrapper)Ú functoolsÚwrapsr rrr )r!r0©rrr rÚ decorator3s z%_dcp_method_logger..decorator)rr r )rrr4rr3rÚ_dcp_method_logger.s#r5)F)r1r$ÚtypingrrrrrZtyping_extensionsrZtorch.distributed.c10d_loggerZ distributedrZ-torch.distributed.checkpoint.logging_handlersrr rÚ__annotations__Z_get_or_create_loggerr*r r rrÚboolr5rrrrÚs$   ÿþ