2022-06-21 15:13:29 -07:00
|
|
|
from ray._private.ray_constants import env_integer
|
2021-07-27 14:05:44 +08:00
|
|
|
|
2020-08-25 04:24:23 +08:00
|
|
|
DASHBOARD_LOG_FILENAME = "dashboard.log"
|
2020-07-27 11:34:47 +08:00
|
|
|
DASHBOARD_AGENT_LOG_FILENAME = "dashboard_agent.log"
|
|
|
|
|
DASHBOARD_AGENT_CHECK_PARENT_INTERVAL_SECONDS = 2
|
2022-07-13 09:05:26 -07:00
|
|
|
RAY_STATE_SERVER_MAX_HTTP_REQUEST_ENV_NAME = "RAY_STATE_SERVER_MAX_HTTP_REQUEST"
|
|
|
|
|
# Default number of in-progress requests to the state api server.
|
|
|
|
|
RAY_STATE_SERVER_MAX_HTTP_REQUEST = env_integer(
|
|
|
|
|
RAY_STATE_SERVER_MAX_HTTP_REQUEST_ENV_NAME, 100
|
|
|
|
|
)
|
|
|
|
|
# Max allowed number of in-progress requests could be configured.
|
|
|
|
|
RAY_STATE_SERVER_MAX_HTTP_REQUEST_ALLOWED = 1000
|
|
|
|
|
|
2020-08-25 04:24:23 +08:00
|
|
|
RETRY_REDIS_CONNECTION_TIMES = 10
|
|
|
|
|
CONNECT_REDIS_INTERNAL_SECONDS = 2
|
2020-07-27 11:34:47 +08:00
|
|
|
PURGE_DATA_INTERVAL_SECONDS = 60 * 10
|
2020-10-28 14:49:31 +08:00
|
|
|
ORGANIZE_DATA_INTERVAL_SECONDS = 2
|
2021-12-21 16:58:03 -08:00
|
|
|
DASHBOARD_RPC_ADDRESS = "dashboard_rpc"
|
|
|
|
|
GCS_SERVER_ADDRESS = "GcsServerAddress"
|
2021-07-27 14:05:44 +08:00
|
|
|
# GCS check alive
|
|
|
|
|
GCS_CHECK_ALIVE_MAX_COUNT_OF_RPC_ERROR = env_integer(
|
|
|
|
|
"GCS_CHECK_ALIVE_MAX_COUNT_OF_RPC_ERROR", 10
|
|
|
|
|
)
|
|
|
|
|
GCS_CHECK_ALIVE_INTERVAL_SECONDS = env_integer("GCS_CHECK_ALIVE_INTERVAL_SECONDS", 5)
|
2021-09-03 14:23:56 -07:00
|
|
|
GCS_CHECK_ALIVE_RPC_TIMEOUT = env_integer("GCS_CHECK_ALIVE_RPC_TIMEOUT", 10)
|
2021-07-27 14:05:44 +08:00
|
|
|
GCS_RETRY_CONNECT_INTERVAL_SECONDS = env_integer(
|
|
|
|
|
"GCS_RETRY_CONNECT_INTERVAL_SECONDS", 2
|
|
|
|
|
)
|
2020-10-10 13:27:05 +08:00
|
|
|
# aiohttp_cache
|
|
|
|
|
AIOHTTP_CACHE_TTL_SECONDS = 2
|
|
|
|
|
AIOHTTP_CACHE_MAX_SIZE = 128
|
|
|
|
|
AIOHTTP_CACHE_DISABLE_ENVIRONMENT_KEY = "RAY_DASHBOARD_NO_CACHE"
|
2020-07-27 11:34:47 +08:00
|
|
|
# Named signals
|
|
|
|
|
SIGNAL_NODE_INFO_FETCHED = "node_info_fetched"
|
2020-10-28 14:49:31 +08:00
|
|
|
SIGNAL_NODE_SUMMARY_FETCHED = "node_summary_fetched"
|
2020-12-31 11:12:17 +08:00
|
|
|
SIGNAL_JOB_INFO_FETCHED = "job_info_fetched"
|
2020-10-28 14:49:31 +08:00
|
|
|
SIGNAL_WORKER_INFO_FETCHED = "worker_info_fetched"
|
|
|
|
|
# Default value for datacenter (the default value in protobuf)
|
|
|
|
|
DEFAULT_LANGUAGE = "PYTHON"
|
|
|
|
|
DEFAULT_JOB_ID = "ffff"
|
2022-03-22 00:21:15 +08:00
|
|
|
# Cache TTL for bad runtime env. After this time, delete the cache and retry to create
|
|
|
|
|
# runtime env if needed.
|
|
|
|
|
BAD_RUNTIME_ENV_CACHE_TTL_SECONDS = env_integer(
|
|
|
|
|
"BAD_RUNTIME_ENV_CACHE_TTL_SECONDS", 60 * 10
|
|
|
|
|
)
|
2022-07-08 10:51:59 -07:00
|
|
|
# Hook that is invoked on the dashboard `/api/component_activities` endpoint.
|
|
|
|
|
# Environment variable stored here should be a callable that does not
|
|
|
|
|
# take any arguments and should return a dictionary mapping
|
|
|
|
|
# activity component type (str) to
|
|
|
|
|
# ray.dashboard.modules.snapshot.snapshot_head.RayActivityResponse.
|
|
|
|
|
# Example: "your.module.ray_cluster_activity_hook".
|
|
|
|
|
RAY_CLUSTER_ACTIVITY_HOOK = "RAY_CLUSTER_ACTIVITY_HOOK"
|
