Struct SlurmSubmitTask 

pub struct SlurmSubmitTask {
    pub job_name: String,
    pub script: String,
    pub partition: Option<String>,
    pub submit_host: String,
    pub submit_user: String,
}

Submit a slurm job via sbatch.

Fields

job_name: String

script: String

partition: Option<String>

submit_host: String

submit_user: String

Trait Implementations

impl DagTask for SlurmSubmitTask

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.