&`iIddlmZddlmZmZmZmZmZddlm Z ddl m Z ddl m Z ddlmZer*ddlmZddlmZdd lmZdd lmZdd lmZmZmZmZdd lmZeGd de ZeGdde Z eGdde Z!eGdde Z"eGdde Z#dS))contextmanager) TYPE_CHECKINGAnyDictListOptional)_TrainingReport)RayTrainCallback) ScalingConfig) DeveloperAPI)TrainRunContext)TrainControllerState)FailureDecision)ResizeDecision)Worker WorkerGroupWorkerGroupContextWorkerGroupPollStatus)ResultceZdZdeddeeeeffdZedZ ddZ dd Z dd Z ed Z ddZddZ ddZddZddZdS)WorkerGroupCallbackworkersrreturnciS)aJCalled before initializing the TrainContext for the worker_group. Return: A dictionary of additional arguments for TrainContext. The key is the argument name and the value is a list of argument values to pass to the TrainContext constructor of each worker in the worker group. )selfrs }/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/ray/train/v2/_internal/execution/callback.pybefore_init_train_contextz-WorkerGroupCallback.before_init_train_contexts  c#KdVdSNrrs ron_worker_group_startz)WorkerGroupCallback.on_worker_group_start' rworker_group_contextrcdS)z6Called before the worker group actors are initialized.Nrrr%s rbefore_worker_group_startz-WorkerGroupCallback.before_worker_group_start+ r worker_grouprcdS)zkCalled after the worker group actors are initialized. All workers should be ready to execute tasks.Nrrr*s rafter_worker_group_startz,WorkerGroupCallback.after_worker_group_start/  rcdSr!rr,s r!after_worker_group_training_startz5WorkerGroupCallback.after_worker_group_training_start4 rc#KdVdSr!rr"s ron_worker_group_shutdownz,WorkerGroupCallback.on_worker_group_shutdown7r$rcdS)zCalled before the worker group is shut down. Workers may be dead at this point due to actor failures, so this method should catch and handle exceptions if attempting to execute tasks.Nrr,s rbefore_worker_group_shutdownz0WorkerGroupCallback.before_worker_group_shutdown;s  rcdS)z+Called after the worker group is shut down.Nrr's rafter_worker_group_shutdownz/WorkerGroupCallback.after_worker_group_shutdownAr)rworker_group_statusrcdSr!r)rr8s rafter_worker_group_poll_statusz2WorkerGroupCallback.after_worker_group_poll_statusEr.rcdS)z*Called before the worker group is aborted.Nrr's rbefore_worker_group_abortz-WorkerGroupCallback.before_worker_group_abortJr)rcdS)z)Called after the worker group is aborted.Nrr's rafter_worker_group_abortz,WorkerGroupCallback.after_worker_group_abortNr)rN)r%r)r*r)r8r)__name__ __module__ __qualname__rrstrrrrr#r(r-r0r3r5r7r:r<r>rrrrrs' H~  c49n     ^            ^         #:              rrc |eZdZddZdededeeeeffdZ dZ dd Z ddZ ddZ ddZdS)ControllerCallbacktrain_run_contextr cdS)zkCalled immediately after `TrainController.run` is called, before the control loop starts executing.Nr)rrEs rafter_controller_startz)ControllerCallback.after_controller_startUr.rscaling_config num_workersrcdS)aCalled by the TrainController before the worker group is started. This hook can be used to perform setup that modifies the worker group's placement, such as reserving an accelerator slice. Args: scaling_config: The scaling configuration for the run. num_workers: The number of workers to be started. Returns: An optional dictionary defining a `label_selector` to gang schedule the worker group on the reserved TPU slice. Nr)rrHrIs r on_controller_start_worker_groupz3ControllerCallback.on_controller_start_worker_group^s trcdS)zUCalled before `TrainController.run` exits, after the control loop has exited.Nrr"s rbefore_controller_shutdownz-ControllerCallback.before_controller_shutdownpr.rprevious_stater current_statecdS)z0Called whenever the controller state is updated.Nr)rrNrOs rafter_controller_state_updatez0ControllerCallback.after_controller_state_updateu rfailure_decisionrcdS)z9Called before the controller executes a failure decision.Nr)rrSs r*before_controller_execute_failure_decisionz=ControllerCallback.before_controller_execute_failure_decision} rresize_decisionrcdS)z8Called before the controller executes a resize decision.Nr)rrWs r)before_controller_execute_resize_decisionzr{sW%%%%%%;;;;;;;;;;;;;;LLLLLL666666111111------ /HHHHHHRQQQQQNNNNNN /.....6 6 6 6 6 *6 6 6 r= = = = = )= = = B      %          %   "     +     r