Struct RaySubmitTask 

pub struct RaySubmitTask {
    pub job_name: String,
    pub entrypoint: String,
    pub head_address: String,
    pub dashboard_port: u16,
    pub working_dir: Option<String>,
}

Submit a ray job via the Ray Jobs API.

Fields

job_name: String

entrypoint: String

head_address: String

dashboard_port: u16

working_dir: Option<String>

Trait Implementations

impl DagTask for RaySubmitTask

fn execute(&self, ctx: &DagContext) -> TaskOutcome

Execute this task.

fn describe(&self) -> String

Human-readable description for logging/monitoring.

fn resource_tag(&self) -> Option<&str>

Optional resource tag for worker pool slot management. Tasks with a resource tag require a matching slot in the pool.