Enum JobEvent 

pub enum JobEvent {
    Ready {
        workflow_id: String,
        job_id: String,
    },
    Started {
        workflow_id: String,
        job_id: String,
        worker_id: String,
    },
    Completed {
        workflow_id: String,
        job_id: String,
        outputs: HashMap<String, String>,
    },
    Failed {
        workflow_id: String,
        job_id: String,
        error: String,
        retryable: bool,
    },
    Cancelled {
        workflow_id: String,
        job_id: String,
    },
    LeaseExpired {
        workflow_id: String,
        job_id: String,
        worker_id: String,
    },
}

Events emitted by the queue for the scheduler to react to.

Variants

Ready

Fields

workflow_id: String

job_id: String

Started

Fields

workflow_id: String

job_id: String

worker_id: String

Completed

Fields

workflow_id: String

job_id: String

outputs: HashMap<String, String>

Failed

Fields

workflow_id: String

job_id: String

error: String

retryable: bool

Cancelled

Fields

workflow_id: String

job_id: String

LeaseExpired

Fields

workflow_id: String

job_id: String

worker_id: String

Trait Implementations

impl Clone for JobEvent

fn clone(&self) -> JobEvent

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for JobEvent

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.