flytekitplugins.ray.RayJobConfig

class flytekitplugins.ray.RayJobConfig(worker_node_config: List[flytekitplugins.ray.task.WorkerNodeConfig], head_node_config: flytekitplugins.ray.task.HeadNodeConfig | None = None, enable_autoscaling: bool = False, runtime_env: dict | None = None, address: str | None = None, shutdown_after_job_finishes: bool = False, ttl_seconds_after_finished: int | None = None)

Methods

Attributes

Parameters:

• worker_node_config (List[WorkerNodeConfig])

• head_node_config (HeadNodeConfig | None)

• enable_autoscaling (bool)

• runtime_env (dict | None)

• address (str | None)

• shutdown_after_job_finishes (bool)

• ttl_seconds_after_finished (int | None)

address: str | None = None

enable_autoscaling: bool = False

head_node_config: HeadNodeConfig | None = None

runtime_env: dict | None = None

shutdown_after_job_finishes: bool = False

ttl_seconds_after_finished: int | None = None

worker_node_config: List[WorkerNodeConfig]