
    &`i                        d 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m	Z	 d Z
d ZddZd	 Zdd
Zedk    r#ddlZ ej                    Ze                    ddd           e                    ded           e                                \  ZZej        r)ej                             ej                    d          Znej        Z eeej                   ej        s/ ej         ej        d          j         g          Z! e"e!            eeej                   ej        s3 ej         ej        d          j         g          Z! e"e!           dS dS dS )z5Examples using MLfowLoggerCallback and setup_mlflow.
    N)tune)MLflowLoggerCallbacksetup_mlflowc                 *    d|| z  dz  z   dz  |dz  z   S )N皙?d    )stepwidthheights      t/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/ray/tune/examples/mlflow_example.pyevaluation_fnr      s$    %$,$$"-<<    c                     | d         | d         }}t          |                     dd                    D ]>}t          |||          }t          j        ||d           t          j        d           ?d S )Nr   r   stepsr   
iterations	mean_lossr   )rangegetr   r   reporttimesleepconfigr   r   r   intermediate_scores        r   train_functionr      s}    7OVH%56Efjj#..//  *4??46HIIJJJ
3 r   Fc                 4   t          j        t          t          j        dt	          | dd          g          t          j        d          t          j        dd	          t          j        d
d	          |rdnd	d          }|                                 d S )NmlflowexampleT)tracking_uriexperiment_namesave_artifact)name	callbacks   num_samples
   r   r   )r   r   r   
run_configtune_configparam_space)r   Tunerr   	RunConfigr   
TuneConfigrandintfitmlflow_tracking_urifinish_fasttuners      r   tune_with_callbackr8      s    J>$!4$-"&  	
 	
 	
 O
 
 
 \"c**l1c**%.QQ3
 
  E* 
IIKKKKKr   c                 P   t          |            | d         | d         }}t          |                     dd                    D ]b}t          |||          }t	          j        t          |          |           t          j        ||d           t          j
        d           cd S )	Nr   r   r   r   )r   )r   r   r   )r   r   r   r   r    log_metricsdictr   r   r   r   r   s        r   train_function_mlflowr<   8   s     7OVH%56Efjj#..//  *4??4*<===DIIII46HIIJJJ
3 r   c                    t          j        |            t          j        d           t          j        t
          t          j        d          t          j        d          t          j        dd          t          j        d	d          |rdnddt          j	                    d
d          }|
                                 d S )Nmixin_example)r#   r    )r%   r'   r(   r*   r   r   )r#   r"   )r   r   r   r    r+   )r    set_tracking_uriset_experimentr   r/   r<   r0   r1   r2   get_tracking_urir3   r4   s      r   tune_with_setuprB   H   s    
/000
/::::J>
 
 
 O
 
 
 \"c**l1c**%.QQ3#2 & 7 9 9 	
 
  E$ 
IIKKKKKr   __main__z--smoke-test
store_truezFinish quickly for testing)actionhelpz--tracking-uriz0The tracking URI for the MLflow tracking server.)typerF   mlruns)r6   r!   r>   )F)#__doc__ostempfiler   r    rayr   ray.air.integrations.mlflowr   r   r   r   r8   r<   rB   __name__argparseArgumentParserparseradd_argumentstrparse_known_argsargs_
smoke_testpathjoin
gettempdirr5   r"   search_runsget_experiment_by_nameexperiment_iddfprintr
   r   r   <module>r`      sA    				          J J J J J J J J= = =	 	 	   4      2 zOOO$X$&&F
|2N     ?    
 %%''GD! 0 gll+>8+>+@+@(KK"/*HHHH? V*V*955CD
 
 	b			O'T_EEEE? V*V*?;;IJ
 
 	b					? 6 r   