o
    $if                     @   s  d Z ddlZddlZddlZddlZeeZdd Zdd Z	dd Z
d	d
 ZeddZe
ddZe
ddZejddZdZdZdZdZdZe	ddZe	ddZe	ddZe	ddZed d!Zed"d#Zed$d%Ze	d&d'Zd(Zd)Z d*Z!d+Z"d,Z#d-Z$d.Z%d/Z&d0Z'd1Z(d2Z)d3Z*d4Z+d5Z,d6Z-d7Z.d8Z/ed9d:Z0d;Z1d<Z2d=Z3d>Z4d?Z5d@Z6dZ7dZ8dZ9dZ:dZ;dAZ<dBZ=edCdDZ>dEZ?dFZ@dGZAdHZBdIZCdJZDdKZEdLZFdMZGdNZHdOZIdPZJdQZKdRZLdSZMdTZNdUZOdVZPdWZQdXZRdYZSdZZTed[dZUd\ZVeWeVXd]d^ZYd_eY ZZejd`daZ[g dbZ\dcZ]ddZ^deZ_dfZ`dgZadhZbdiZcd=ZddjZedkZfdlZgdmZhdnZidoZjdpZkdqZlea drZmec drZne
dsdZoedtduZpdvZqejdweqZrejdxZsdyZtdzZud{Zvd|eu Zwd|ev Zxd}eu Zyd~ev Zzdeu Z{dev Z|e}ejddZ~e}ejddZdZdZdZdZdZdZdZdZdZdZdZdZdZd;ZdZdZdZdZdZejddZdZdZd3ZdZdZeddZejdd dv rdndZdeffZdZdZdZdZdZdZdZdZdZdZg dZdZdZdZdZdZdZdZdZg dZdd Zh dZg dZejdkpejdkZdZe
ee ZdZdZe}ejddZh dZe
ddZdZdZdZdZdZejdšZdZe
ddZejddZeŠdɡZe
dd˃Ze
dd̓Ze
ddZejddСZe
ddZeddӃd Ze
ddZdS )z&Ray constants used in the Python code.    Nc              	   C   sP   | t jv r&t j|  }| rtt j|  S td|  d| d| d |S |S )NFound z4 in environment, but value must be an integer. Got: . Returning provided default .)osenvironisdigitintloggerdebugkeydefaultvalue r   W/home/ubuntu/veenaModal/venv/lib/python3.10/site-packages/ray/_private/ray_constants.pyenv_integer   s   

r   c                 C   sX   | t jv r*t j|  }zt|W S  ty)   td|  d| d| d | Y S w |S )Nr   z1 in environment, but value must be a float. Got: r   r   )r   r   float
ValueErrorr	   r
   r   r   r   r   	env_float   s   


r   c                 C   s6   | t jv rt j|   dkst j|  dkrdS dS |S )Ntrue1TF)r   r   lower)r   r   r   r   r   env_bool)   s   
 r   c                 C   s
   | t jv S )N)r   r   )r   r   r   r   env_set_by_user3   s   
r   RAY_SCHEDULER_EVENTS   "RAY_DISABLE_FAILURE_SIGNAL_HANDLERFRAY_LOG_TO_DRIVERTRAY_LOG_TO_DRIVER_EVENT_LEVELINFO__autoscaling_error__autoscaling_status__autoscaling_status_legacy   z/sys/fs/cgroup*RAY_DEFAULT_SYSTEM_RESERVED_CPU_PROPORTIONg?)RAY_DEFAULT_MIN_SYSTEM_RESERVED_CPU_CORESg      ?)RAY_DEFAULT_MAX_SYSTEM_RESERVED_CPU_CORESg      @-RAY_DEFAULT_SYSTEM_RESERVED_MEMORY_PROPORTIONg?,RAY_DEFAULT_MIN_SYSTEM_RESERVED_MEMORY_BYTESi  @,RAY_DEFAULT_MAX_SYSTEM_RESERVED_MEMORY_BYTESl       
 )RAY_DEFAULT_OBJECT_STORE_MAX_MEMORY_BYTESl    P! *RAY_DEFAULT_OBJECT_STORE_MEMORY_PROPORTIONg333333?i  i  l    d(	 l        i  RAY_ADDRESSRAY_API_SERVER_ADDRESSRAY_NAMESPACERAY_RUNTIME_ENV0RAY_RUNTIME_ENV_TEMPORARY_REFERENCE_EXPIRATION_S"RAY_RUNTIME_ENV_CREATE_WORKING_DIRiX   RAY_RUNTIME_ENV_IGNORE_GITIGNORERAY_RUNTIME_ENV_HOOKRAY_START_HOOKRAY_JOB_SUBMIT_HOOKRAY_JOB_HEADERSRAY_DASHBOARD_STARTUP_TIMEOUT_S<   z	127.0.0.1iI   	dashboardi  @z#prom_metrics_service_discovery.jsoni     i FUNCTION_SIZE_ERROR_THRESHOLDi d   g  ļBg-C6?RAY_OVERRIDE_DASHBOARD_URLpickling_large_objectwait_for_functionversion_mismatchworker_crashworker_diedworker_pool_largeput_reconstructionresource_deadlocknode_removedmonitor_diedlog_monitor_dieddashboard_agent_dieddashboard_diedraylet_died"detached_actor_anonymous_namespaceexcess_queueing_warningRAY_OVERRIDE_RESOURCESRAY_OVERRIDE_LABELSRAY_DISABLE_DASHBOARD_LOG_INFOz@%(asctime)s	%(levelname)s %(filename)s:%(lineno)s -- %(message)s%z%%zThe logging format. default=RAY_LOGGER_LEVELinfo)r
   rS   warningerrorcriticalzfThe logging level threshold, choices=['debug', 'info', 'warning', 'error', 'critical'], default='info'RAY_LOG_TO_STDERRzN%(asctime)s	%(levelname)s ({component}) %(filename)s:%(lineno)s -- %(message)sreapermonitorray_client_serverlog_monitordashboard_agentruntime_env_agentworkerrayletredis_server
gcs_serverzpython-core-driverzpython-core-workerz.logRAY_DEDUP_LOGSRAY_DEDUP_LOGS_AGG_WINDOW_S   !__ray_testing_never_deduplicate__RAY_DEDUP_LOGS_ALLOW_REGEXRAY_DEDUP_LOGS_SKIP_REGEXz	ray::IDLESpillWorkerRestoreWorkerz
ray::IDLE_zray::SPILL_zray::RESTORE_zray::DELETE_RAY_LOG_MONITOR_MAX_OPEN_FILES200!RAY_LOG_MONITOR_NUM_LINES_TO_READ1000z:event_summary:z:info_message:z:actor_name:z:task_name:z:job_id:s   XLANGs   PYTHONs   RAWs   ACTOR_HANDLEs   DEBUG:s   autoscaler_resource_request i   i  l    ray_spilled_objectsRAY_GCS_SERVER_PORTRAY_HEALTHCHECK_EXPIRATION_S
   zsetup_worker.pyruntime_resourcesz | i    AGENT_GRPC_MAX_MESSAGE_LENGTHi  @RAY_grpc_enable_http_proxy0)r   r   zgrpc.enable_http_proxys	   dashboards   sessions   tracings   ray_pdbs   healthchecks   jobs   clusters   head_node_ids   fun)pythonjavacppneuron_coresGPUTPUNPUHPURAY_worker_niceness   )
RAY_JOB_IDRAY_RAYLET_PID RAY_OVERRIDE_NODE_ID_FOR_TESTINGc                   C   s   t jddkS )N RAY_gcs_actor_scheduling_enabledr   )r   r   getr   r   r   r   gcs_actor_scheduling_enabled  s   r   >   CPUr{   memoryobject_store_memory))r   	   )r   rr   )r      )r      darwinwin32!RAY_ENABLE_WINDOWS_OR_OSX_CLUSTERsession_latest(   RAY_NUM_REDIS_GET_RETRIES20>   gcs_server_portmetrics_agent_portmetrics_export_portruntime_env_agent_portdashboard_agent_listen_port$RAY_ENABLE_RECORD_ACTOR_TASK_LOGGING'__RAY_WORKER_PROCESS_SETUP_HOOK_ENV_VAR*RAY_WORKER_PROCESS_SETUP_HOOK_LOAD_TIMEOUTzray.io/)RAY_TPU_MAX_CONCURRENT_ACTIVE_CONNECTIONSznode_ip_address.jsonRAY_LOGGING_CONFIG_ENCODINGRAY_BACKEND_LOG_JSONRAY_enable_export_api_write"RAY_enable_export_api_write_config,$RAY_EXPORT_EVENT_MAX_FILE_SIZE_BYTESg    חA!RAY_EXPORT_EVENT_MAX_BACKUP_COUNT   RAY_ENABLE_UV_RUN_RUNTIME_ENVRAY_metric_cardinality_levelrecommendedRAY_enable_open_telemetry'RAY_rdt_fetch_fail_timeout_millisecondsi`  i  "RAY_ENABLE_ZERO_COPY_TORCH_TENSORS)__doc__jsonloggingr   sys	getLogger__name__r	   r   r   r   r   AUTOSCALER_EVENTSr   r   r   r   r   DEBUG_AUTOSCALING_ERRORDEBUG_AUTOSCALING_STATUSDEBUG_AUTOSCALING_STATUS_LEGACYID_SIZEDEFAULT_CGROUP_PATH&DEFAULT_SYSTEM_RESERVED_CPU_PROPORTION%DEFAULT_MIN_SYSTEM_RESERVED_CPU_CORES%DEFAULT_MAX_SYSTEM_RESERVED_CPU_CORES)DEFAULT_SYSTEM_RESERVED_MEMORY_PROPORTION(DEFAULT_MIN_SYSTEM_RESERVED_MEMORY_BYTES(DEFAULT_MAX_SYSTEM_RESERVED_MEMORY_BYTES%DEFAULT_OBJECT_STORE_MAX_MEMORY_BYTES&DEFAULT_OBJECT_STORE_MEMORY_PROPORTION!OBJECT_STORE_MINIMUM_MEMORY_BYTES"CALLER_MEMORY_USAGE_PER_OBJECT_REFREQUIRE_SHM_SIZE_THRESHOLD!MAC_DEGRADED_PERF_MMAP_SIZE_LIMITDEFAULT_PORT RAY_ADDRESS_ENVIRONMENT_VARIABLE+RAY_API_SERVER_ADDRESS_ENVIRONMENT_VARIABLE"RAY_NAMESPACE_ENVIRONMENT_VARIABLE$RAY_RUNTIME_ENV_ENVIRONMENT_VARIABLE,RAY_RUNTIME_ENV_URI_PIN_EXPIRATION_S_ENV_VAR*RAY_RUNTIME_ENV_CREATE_WORKING_DIR_ENV_VAR,RAY_RUNTIME_ENV_URI_PIN_EXPIRATION_S_DEFAULTr2   r3   r4   r5   r6   r7   DEFAULT_DASHBOARD_IPDEFAULT_DASHBOARD_PORTDASHBOARD_ADDRESSDASHBOARD_CLIENT_MAX_SIZE!PROMETHEUS_SERVICE_DISCOVERY_FILE#DEFAULT_DASHBOARD_AGENT_LISTEN_PORTDEFAULT_ACTOR_METHOD_CPU_SIMPLE!DEFAULT_ACTOR_CREATION_CPU_SIMPLE"DEFAULT_ACTOR_METHOD_CPU_SPECIFIED$DEFAULT_ACTOR_CREATION_CPU_SPECIFIED$DEFAULT_ACTOR_METHOD_NUM_RETURN_VALS%DEFAULT_CLIENT_RECONNECT_GRACE_PERIODFUNCTION_SIZE_WARN_THRESHOLDr;   #DUPLICATE_REMOTE_FUNCTION_THRESHOLDMAX_RESOURCE_QUANTITYMIN_RESOURCE_GRANULARITYr=    PICKLING_LARGE_OBJECT_PUSH_ERRORWAIT_FOR_FUNCTION_PUSH_ERRORVERSION_MISMATCH_PUSH_ERRORWORKER_CRASH_PUSH_ERRORWORKER_DIED_PUSH_ERRORWORKER_POOL_LARGE_ERRORPUT_RECONSTRUCTION_PUSH_ERRORRESOURCE_DEADLOCK_ERRORREMOVED_NODE_ERRORMONITOR_DIED_ERRORLOG_MONITOR_DIED_ERRORDASHBOARD_AGENT_DIED_ERRORDASHBOARD_DIED_ERRORRAYLET_DIED_ERROR(DETACHED_ACTOR_ANONYMOUS_NAMESPACE_ERROREXCESS_QUEUEING_WARNINGRESOURCES_ENVIRONMENT_VARIABLELABELS_ENVIRONMENT_VARIABLEDISABLE_DASHBOARD_LOG_INFOLOGGER_FORMATdumpsreplaceLOGGER_FORMAT_ESCAPELOGGER_FORMAT_HELPLOGGER_LEVELLOGGER_LEVEL_CHOICESLOGGER_LEVEL_HELP,LOGGING_REDIRECT_STDERR_ENVIRONMENT_VARIABLELOGGER_FORMAT_STDERRPROCESS_TYPE_REAPERPROCESS_TYPE_MONITORPROCESS_TYPE_RAY_CLIENT_SERVERPROCESS_TYPE_LOG_MONITORPROCESS_TYPE_DASHBOARDPROCESS_TYPE_DASHBOARD_AGENTPROCESS_TYPE_RUNTIME_ENV_AGENTPROCESS_TYPE_WORKERPROCESS_TYPE_RAYLETPROCESS_TYPE_REDIS_SERVERPROCESS_TYPE_GCS_SERVER&PROCESS_TYPE_PYTHON_CORE_WORKER_DRIVERPROCESS_TYPE_PYTHON_CORE_WORKERMONITOR_LOG_FILE_NAMELOG_MONITOR_LOG_FILE_NAMErb   rc   TESTING_NEVER_DEDUP_TOKENrf   rg   WORKER_PROCESS_TYPE_IDLE_WORKER%WORKER_PROCESS_TYPE_SPILL_WORKER_NAME'WORKER_PROCESS_TYPE_RESTORE_WORKER_NAME%WORKER_PROCESS_TYPE_SPILL_WORKER_IDLE'WORKER_PROCESS_TYPE_RESTORE_WORKER_IDLE WORKER_PROCESS_TYPE_SPILL_WORKER"WORKER_PROCESS_TYPE_RESTORE_WORKER'WORKER_PROCESS_TYPE_SPILL_WORKER_DELETE)WORKER_PROCESS_TYPE_RESTORE_WORKER_DELETEr   LOG_MONITOR_MAX_OPEN_FILESLOG_MONITOR_NUM_LINES_TO_READLOG_PREFIX_EVENT_SUMMARYLOG_PREFIX_INFO_MESSAGELOG_PREFIX_ACTOR_NAMELOG_PREFIX_TASK_NAMELOG_PREFIX_JOB_ID#OBJECT_METADATA_TYPE_CROSS_LANGUAGEOBJECT_METADATA_TYPE_PYTHONOBJECT_METADATA_TYPE_RAW!OBJECT_METADATA_TYPE_ACTOR_HANDLEOBJECT_METADATA_DEBUG_PREFIX#AUTOSCALER_RESOURCE_REQUEST_CHANNELREDIS_DEFAULT_USERNAMEREDIS_DEFAULT_PASSWORDNODE_DEFAULT_IPMACH_PAGE_SIZE_BYTESMAX_APPLICATION_ERROR_LENMAX_INT64_VALUEDEFAULT_OBJECT_PREFIXGCS_PORT_ENVIRONMENT_VARIABLEHEALTHCHECK_EXPIRATION_SSETUP_WORKER_FILENAMEDEFAULT_RUNTIME_ENV_DIR_NAME#DEFAULT_RUNTIME_ENV_TIMEOUT_SECONDSCALL_STACK_LINE_DELIMITERGRPC_CPP_MAX_MESSAGE_SIZErt   r   GRPC_ENABLE_HTTP_PROXYGLOBAL_GRPC_OPTIONSKV_NAMESPACE_DASHBOARDKV_NAMESPACE_SESSIONKV_NAMESPACE_TRACINGKV_NAMESPACE_PDBKV_NAMESPACE_HEALTHCHECKKV_NAMESPACE_JOBKV_NAMESPACE_CLUSTERKV_HEAD_NODE_ID_KEYKV_NAMESPACE_PACKAGEKV_NAMESPACE_FUNCTION_TABLELANGUAGE_WORKER_TYPESNEURON_CORESr{   r|   r}   r~   RAY_WORKER_NICENESSDEFAULT_TASK_MAX_RETRIES DEFAULT_MAX_CONCURRENCY_THREADEDRAY_INTERNAL_FLAGSr   DEFAULT_RESOURCESRUNTIME_ENV_CONDA_PY_VERSIONSplatformIS_WINDOWS_OR_OSXENABLE_RAY_CLUSTERS_ENV_VARENABLE_RAY_CLUSTERSESSION_LATESTNUM_PORT_RETRIESNUM_REDIS_GET_RETRIESRAY_ALLOWED_CACHED_PORTSr   !WORKER_PROCESS_SETUP_HOOK_ENV_VAR2RAY_WORKER_PROCESS_SETUP_HOOK_LOAD_TIMEOUT_ENV_VARRAY_DEFAULT_LABEL_KEYS_PREFIX*RAY_TPU_MAX_CONCURRENT_CONNECTIONS_ENV_VARRAY_NODE_IP_FILENAMEr   RAY_BACKEND_LOG_JSON_ENV_VARRAY_ENABLE_EXPORT_API_WRITE&RAY_ENABLE_EXPORT_API_WRITE_CONFIG_STRsplit"RAY_ENABLE_EXPORT_API_WRITE_CONFIGr   r   r   RAY_METRIC_CARDINALITY_LEVELRAY_ENABLE_OPEN_TELEMETRYRDT_FETCH_FAIL_TIMEOUT_SECONDSr   r   r   r   r   <module>   s   












	


	


	
