
    &`i                     :   d dl Z d dlZd dlZd dlZd dlZd dlmZ d dlmZ d Z	d Z
edk    r e j                    Ze                    ddd	
           e                                \  ZZ ej        e
 ej        ddej        rdndi           ej        ddd          d ej        dd           ej        dd          d          Ze                                Ze                                Z edej                   ej        Z  ede            dS dS )    N)tune)
Checkpointc                 R    t          j        d           d|| z  dz  z   dz  |dz  z   S )Ng?d   )timesleep)stepwidthheights      /home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/ray/tune/examples/custom_func_checkpointing.pyevaluation_fnr      s1    JsOOO%$,$$"-<<    c                 "   d}| d         | d         }}t          j                    }|r|                                5 }t          t          j                            |d                    5 }t          j        |          }d d d            n# 1 swxY w Y   |d         dz   }d d d            n# 1 swxY w Y   t          |d          D ]}t          |||          }	t          j                    5 }
t          t          j                            |
d          d          5 }t          j        d|i|           d d d            n# 1 swxY w Y   t          j        ||	d	t          j        |
          
           d d d            n# 1 swxY w Y   d S )Nr   r   r   zcheckpoint.jsonr
      r   w)
iterations	mean_loss)
checkpoint)r   get_checkpointas_directoryopenospathjoinjsonloadranger   tempfileTemporaryDirectorydumpreportr   from_directory)configr
   r   r   r   checkpoint_dirfstatecurrent_stepintermediate_scoretemp_checkpoint_dirs              r   
train_funcr+      sy   D7OVH%56E$&&J %$$&& 	%.bgll>3DEEFF %!	!% % % % % % % % % % % % % % %=1$D	% 	% 	% 	% 	% 	% 	% 	% 	% 	% 	% 	% 	% 	% 	%
 dC(( 	 	*<GG(** 	.Abgll#68IJJCPP 5TU	6<0!4445 5 5 5 5 5 5 5 5 5 5 5 5 5 5K+:LMM%45HII   	 	 	 	 	 	 	 	 	 	 	 	 	 	 		 	sk   .B-*B?B-B	B-B	B--B14B1./FE5FEFE	.FF	
F	__main__z--smoke-test
store_truezFinish quickly for testing)actionhelphyperband_testtraining_iterationr   
   )namestopr   min   )metricmodenum_samplesr   )stepsr   r   )
run_configtune_configparam_spacezBest hyperparameters: zBest checkpoint: )!argparser   r   r   r   rayr   ray.tuner   r   r+   __name__ArgumentParserparseradd_argumentparse_known_argsargs_Tuner	RunConfig
smoke_test
TuneConfigrandint
loguniformtunerfitresultsget_best_resultbest_resultprintr$   r   best_checkpoint r   r   <module>rV      s     				              = = =
  . z$X$&&F
|2N     %%''GD!DJ!4>!&T_(D"E
 
 
 $DO
 
 
 !T\"c**%dob#..
 
  E" iikkG))++K	E
"K$6777!,O	E
/////9 r   