o zi!@sddlmZmZmZddlmZddlmZeGdddZeGdddeZ eGdd d e Z eGd d d e Z eGd d d eZ eGddde Z eGddde ZeGdddeZeGdddeZdS))asdict dataclassfield)Type)overridec@sPeZdZdZdefddZdeddfddZededdfd d Zd d d Z dS) _BaseProgressz>Mixin that implements state-loading utilities for dataclasses.returncCst|SN)rselfr T/home/ubuntu/.local/lib/python3.10/site-packages/pytorch_lightning/loops/progress.py state_dictsz_BaseProgress.state_dictrNcCs|j|dSr )__dict__updater rr r r load_state_dictsz_BaseProgress.load_state_dictcCs|}|||Sr )r)clsrobjr r r from_state_dicts z_BaseProgress.from_state_dictcCst)zReset the object's state.)NotImplementedErrorr r r r reset$sz_BaseProgress.resetrN) __name__ __module__ __qualname____doc__dictrr classmethodrrr r r r rsrc@sBeZdZUdZdZeed<dZeed<ed ddZ d d d Z dS) _ReadyCompletedTrackeraFTrack an event's progress. Args: ready: Intended to track the number of events ready to start. completed: Intended to be incremented after the event completes (e.g. after ``on_*_end`` runs). These attributes should be increased in order, that is, :attr:`ready` first and :attr:`completed` last. rready completedrNcCsd|_d|_dS)zReset the state.rN)r r!r r r r r8s z_ReadyCompletedTracker.resetcCs |j|_dS)zReset the progress on restart. If there is a failure before all attributes are increased, restore the attributes to the last fully completed value. N)r!r r r r r reset_on_restart>s z'_ReadyCompletedTracker.reset_on_restartr) rrrrr int__annotations__r!rrr"r r r r r)s   rcFeZdZUdZdZeed<ed fdd Zed fdd Z Z S) _StartedTrackeraTrack an event's progress. Args: ready: Intended to track the number of events ready to start. started: Intended to be incremented after the event is started (e.g. after ``on_*_start`` runs). completed: Intended to be incremented after the event completes (e.g. after ``on_*_end`` runs). These attributes should be increased in order, that is, :attr:`ready` first and :attr:`completed` last. rstartedrNctd|_dSNr)superrr'r  __class__r r rW  z_StartedTracker.resetct|j|_dSr )r*r"r!r'r r+r r r"\  z _StartedTracker.reset_on_restartr) rrrrr'r#r$rrr" __classcell__r r r+r r&Hs  r&cr%) _ProcessedTrackeraTrack an event's progress. Args: ready: Intended to track the number of events ready to start. started: Intended to be incremented after the event is started (e.g. after ``on_*_start`` runs). processed: Intended to be incremented after the event is processed. completed: Intended to be incremented after the event completes (e.g. after ``on_*_end`` runs). These attributes should be increased in order, that is, :attr:`ready` first and :attr:`completed` last. r processedrNcr(r))r*rr2r r+r r rrr-z_ProcessedTracker.resetcr.r )r*r"r!r2r r+r r r"wr/z"_ProcessedTracker.reset_on_restartr) rrrrr2r#r$rrr"r0r r r+r r1bs  r1c@seZdZUdZeedZeed<eedZ eed<dddZ dd d Z dd d Z dd dZ dddZedeededdfddZedddZdddZdddZededdfddZdS) _ProgresszTrack aggregated and current progress. Args: total: Intended to track the total progress of an event. current: Intended to track the current progress of an event. default_factorytotalcurrentrNcCs|jj|jjur tddS)Nz?The `total` and `current` instances should be of the same class)r6r,r7 ValueErrorr r r r __post_init__sz_Progress.__post_init__cC$|jjd7_|jjd7_dSN)r6r r7r r r r increment_readyz_Progress.increment_readycCFt|jtstd|jjjd|jjd7_|jjd7_dS)N`z$` doesn't have a `started` attributer<) isinstancer6r& TypeErrorr,rr'r7r r r r increment_started z_Progress.increment_startedcCr?)Nr@z&` doesn't have a `processed` attributer<)rAr6r1rBr,rr2r7r r r r increment_processedrDz_Progress.increment_processedcCr:r;)r6r!r7r r r r increment_completedr>z_Progress.increment_completed tracker_clskwargscKs ||di||di|dS)zZUtility function to easily create an instance from keyword arguments to both ``Tracker``s.)r6r7Nr r )rrGrHr r r from_defaultss z_Progress.from_defaultscC|j|jdSr )r6rr7r r r r r z_Progress.resetcC|jdSr )r7rr r r r reset_on_runz_Progress.reset_on_runcCrLr )r7r"r r r r r"rNz_Progress.reset_on_restartrcC$|j|d|j|ddS)Nr6r7)r6rr7rr r r rz_Progress.load_state_dictr)rrrrrr1r6rr$r7r9r=rCrErFrrr#rIrrrMr"rrr r r r r3}s"         r3cs`eZdZUdZdZeed<ed fdd Zed fdd Z ed e ddffd d Z Z S)_BatchProgressaWTracks batch progress. These counters are local to a trainer rank. By default, they are not globally synced across all ranks. Args: total: Tracks the total batch progress. current: Tracks the current batch progress. is_last_batch: Whether the batch is the last one. This is useful for iterable datasets. F is_last_batchrNcr(NF)r*rrRr r+r r rr-z_BatchProgress.resetcr(rS)r*rMrRr r+r r rMr-z_BatchProgress.reset_on_runrcst||d|_dS)NrR)r*rrRrr+r r rs z_BatchProgress.load_state_dictr) rrrrrRboolr$rrrMrrr0r r r+r rQs   rQc@s6eZdZUdZeedZeed<eedZeed<dS)_SchedulerProgressaTracks scheduler progress. These counters are local to a trainer rank. By default, they are not globally synced across all ranks. Args: total: Tracks the total scheduler progress. current: Tracks the current scheduler progress. r4r6r7N) rrrrrrr6r$r7r r r r rUs  rUc@sveZdZUdZedddZeed<edddZeed<e dd d Z dd d Z dddZ e de dd fddZd S)_OptimizerProgresszTrack optimizer progress. Args: step: Tracks ``optimizer.step`` calls. zero_grad: Tracks ``optimizer.zero_grad`` calls. cC ttSr )r3rIrr r r r  z_OptimizerProgress.r4stepcCrWr )r3rIr&r r r r rXrY zero_gradrNcCrJr )rZrr[r r r r rrKz_OptimizerProgress.resetcCrJr )rZrMr[r r r r rM z_OptimizerProgress.reset_on_runcCrJr )rZr"r[r r r r r"r\z#_OptimizerProgress.reset_on_restartrcCrO)NrZr[)rZrr[rr r r rrPz"_OptimizerProgress.load_state_dictr)rrrrrrZr3r$r[rrrMr"rrr r r r rVs    rVc@sneZdZUdZeedZeed<ede fddZ e ddd Z dd d Z dd d Ze deddfddZdS)_OptimizationProgressz[Track optimization progress. Args: optimizer: Tracks optimizer progress. r4 optimizerrcCs |jjjjSr )r^rZr6r!r r r r optimizer_stepss z%_OptimizationProgress.optimizer_stepsNcCrLr )r^rr r r r rsz_OptimizationProgress.resetcCrLr )r^rMr r r r rMrNz"_OptimizationProgress.reset_on_runcCrLr )r^r"r r r r r"rNz&_OptimizationProgress.reset_on_restartrcCs|j|ddS)Nr^)r^rrr r r r sz%_OptimizationProgress.load_state_dictr)rrrrrrVr^r$propertyr#r_rrrMr"rrr r r r r]s    r]N) dataclassesrrrtypingrtyping_extensionsrrrr&r1r3rQrUrVr]r r r r s*  :