o 8wi@s2ddlmZddlZddlmZGdddZdS))OptionalN) _BaseProgressc@seZdZdZdddZedefdd Zejd eddfd d Zdd d Z de fddZ de ddfddZ d de e dede fddZ d!de deddfddZde deddfddZdddZdS)"_LoopzBasic Loops interface.trainer pl.TrainerreturnNcCsd|_d|_||_dSNF) _restarting_loaded_from_state_dictr)selfrr Y/home/ubuntu/sommelier/.venv/lib/python3.10/site-packages/pytorch_lightning/loops/loop.py__init__s z_Loop.__init__cCs|jS)zDWhether the state of this loop was reloaded and it needs to restart.)r r r r r restartingsz_Loop.restartingrcCs,||_t|D] }t|tr||_q dS)z7Connects this loop's restarting value and its children.N)r varsvalues isinstancerr)r rloopr r r r!s  cCsdS)Nr rr r r reset_restart_stage)sz_Loop.reset_restart_stagecCsiS)zCalled when saving a model checkpoint, use to persist loop state. Returns: The current loop state. r rr r r on_save_checkpoint,sz_Loop.on_save_checkpoint state_dictcCsdS)zACalled when loading a model checkpoint, use to reload loop state.Nr )r rr r r on_load_checkpoint5sz_Loop.on_load_checkpoint destinationprefixcCsn|duri}|||d<|jD]!\}}||}t|tr'|||<qt|tr4|||dq|S)a?The state dict is determined by the state and progress of this loop and all its children. Args: destination: An existing dictionary to update with this loop's state. By default a new dictionary is returned. prefix: A prefix for each key in the state dictionary Nr.)r__dict__itemsrrrr)r rrkvkeyr r r r8s   z_Loop.state_dictcCsV||||jD]\}}t|tr"||||dq d|_d|_dS)z2Loads the state of this loop and all its children.rTN) _load_from_state_dictcopyrrrrload_state_dictrr )r rrrr r r r r$Ns  z_Loop.load_state_dictcCsd|jD]\}}||}||vrqt|tr|||q|d|vr0|||ddSdS)Nr)rrrrr$r)r rrrr r!r r r r"[s  z_Loop._load_from_state_dictcCsd|_d|_|dSr)r r rrr r r on_iteration_donefs z_Loop.on_iteration_done)rrrN)rN)Nr)r)__name__ __module__ __qualname____doc__rpropertyboolrsetterrdictrrrstrrr$r"r%r r r r rs*      r)typingrpytorch_lightningpl pytorch_lightning.loops.progressrrr r r r s