
    &`i5                     H   U d dl Z d dlmZ d dlmZ d dlmZmZ dZdZ	dZ
dZd	Zd
ZdZeed<   dZdZeed<   dZdZeed<   dZdZeed<   dZdZeed<   dZdZdZdZdZdZdZdZ dZ!dZ"dZ#eed <   d!Z$e%ed"<   d#Z&e%ed$<   d%Z'd&Z(eeeeeeeeee e"ehZ)d'Z*d(e+fd)Z,d(ee-e-f         fd*Z.dS )+    N)Dict)*RAY_WARN_BLOCKING_GET_INSIDE_ASYNC_ENV_VAR)env_boolenv_set_by_userUNSUPPORTED
DEPRECATEDz.validate_storage_markerz checkpoint_manager_snapshot.json)zAWS Error SLOW_DOWNzAWS Error INTERNAL_FAILUREzAWS Error SERVICE_UNAVAILABLEzAWS Error NETWORK_CONNECTIONzAWS Error UNKNOWN!RAY_TRAIN_HEALTH_CHECK_INTERVAL_Sg       @DEFAULT_HEALTH_CHECK_INTERVAL_S'RAY_TRAIN_WORKER_HEALTH_CHECK_TIMEOUT_SiX  %DEFAULT_WORKER_HEALTH_CHECK_TIMEOUT_S&RAY_TRAIN_WORKER_GROUP_START_TIMEOUT_Sg      >@$DEFAULT_WORKER_GROUP_START_TIMEOUT_SRAY_TRAIN_COLLECTIVE_TIMEOUT_SDEFAULT_COLLECTIVE_TIMEOUT_S$RAY_TRAIN_COLLECTIVE_WARN_INTERVAL_S<   "DEFAULT_COLLECTIVE_WARN_INTERVAL_SRAY_TRAIN_ENABLE_PRINT_PATCHTRAY_TRAIN_V2_ENABLED.RAY_TRAIN_ENABLE_CONTROLLER_STRUCTURED_LOGGING*RAY_TRAIN_ENABLE_WORKER_STRUCTURED_LOGGING+RAY_TRAIN_ENABLE_STATE_ACTOR_RECONCILIATION/RAY_TRAIN_STATE_ACTOR_RECONCILIATION_INTERVAL_S-DEFAULT_STATE_ACTOR_RECONCILIATION_INTERVAL_S   GET_ACTOR_TIMEOUT_S   !CONTROLLERS_TO_POLL_PER_ITERATIONRAY_TRAIN_CALLBACKS0RAY_TRAIN_METRICS_ENABLEDreturnc                  ,    t          t          d          S )NT)r   V2_ENABLED_ENV_VAR     t/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/ray/train/v2/_internal/constants.pyis_v2_enabledr)   x   s    &---r'   c                  f    i } t           D ]&}t          |          rt          j        |         | |<   '| S )aN  Returns a dictionary of environment variables that should be propagated
    from the driver to the controller, and then from the controller
    to each training worker.

    This way, users only need to set environment variables in one place
    when launching the script instead of needing to manually set a runtime environment.
    )ENV_VARS_TO_PROPAGATEr   osenviron)env_varsenv_vars     r(   get_env_vars_to_propagater0   |   s?     H( 4 47## 	4 "
7 3HWOr'   )/r,   typingr   ray._common.constantsr   ray._private.ray_constantsr   r   _UNSUPPORTED_DEPRECATED VALIDATE_STORAGE_MARKER_FILENAME$CHECKPOINT_MANAGER_SNAPSHOT_FILENAMEAWS_RETRYABLE_TOKENSHEALTH_CHECK_INTERVAL_S_ENV_VARr
   float__annotations__%WORKER_HEALTH_CHECK_TIMEOUT_S_ENV_VARr   $WORKER_GROUP_START_TIMEOUT_S_ENV_VARr   COLLECTIVE_TIMEOUT_S_ENV_VARr   "COLLECTIVE_WARN_INTERVAL_S_ENV_VARr   ENABLE_PRINT_PATCH_ENV_VARDEFAULT_ENABLE_PRINT_PATCHr%   ,ENABLE_CONTROLLER_STRUCTURED_LOGGING_ENV_VAR(ENABLE_WORKER_STRUCTURED_LOGGING_ENV_VAR!DEFAULT_ENABLE_CONTROLLER_LOGGINGDEFAULT_ENABLE_WORKER_LOGGING)ENABLE_STATE_ACTOR_RECONCILIATION_ENV_VAR)DEFAULT_ENABLE_STATE_ACTOR_RECONCILIATION-STATE_ACTOR_RECONCILIATION_INTERVAL_S_ENV_VARr   r   intr   RAY_TRAIN_CALLBACKS_ENV_VAR0DEFAULT_RAY_WARN_BLOCKING_GET_INSIDE_ASYNC_VALUEr+   METRICS_ENABLED_ENV_VARboolr)   strr0   r&   r'   r(   <module>rO      s   					       L L L L L L @ @ @ @ @ @ @ @  $>  'I $ $ #F ),  , , , )R %/6 %u 6 6 6 (P $.2 $e 2 2 2  @  ') e ( ( (%K ",. "E . . . < !  ,  5 - ,X ($( ! $  2 * -1 )5 . 8< -u ; ; ;  S    *+ !3 * * * 4  47 0
 #)( &0,-1. * 6 .t . . . .4S>      r'   