Struct prefect::JobStatus

pub struct JobStatus {

    pub id: Uuid,
    pub job_type: String,
    pub state: JobState,
    pub priority: i32,
    pub weight: u16,
    pub orig_run_at: OffsetDateTime,
    pub run_at: Option<OffsetDateTime>,
    pub payload: Vec<u8>,
    pub current_try: Option<i32>,
    pub max_retries: i32,
    pub backoff_multiplier: f64,
    pub backoff_randomization: f64,
    pub backoff_initial_interval: Duration,
    pub added_at: OffsetDateTime,
    pub started_at: Option<OffsetDateTime>,
    pub finished_at: Option<OffsetDateTime>,
    pub expires_at: Option<OffsetDateTime>,
    pub run_info: SmallVec<[RunInfo<Box<RawValue>>; 4]>,
}

Status information about a job.

Fields

id: Uuid

The job’s ID.

job_type: String

The type of a job

state: JobState

If the job is waiting, running, or finished

priority: i32

Higher priority jobs will be run first.

weight: u16

Higher weight indicates a job counts more against a worker’s concurrency.

orig_run_at: OffsetDateTime

The original run_at time, before any retries.

run_at: Option<OffsetDateTime>

The current run_at time, if the job is pending.

payload: Vec<u8>

The job’s payload

current_try: Option<i32>

The current try count, if the job is running or pending.

max_retries: i32

The limit on the number of retries.

backoff_multiplier: f64

The multiplier used when calculating the next retry time. See Retries.

backoff_randomization: f64

The random factor used when calculating the next retry time. See Retries.

backoff_initial_interval: Duration

The initial delay used when calculating the next retry time. See Retries.

added_at: OffsetDateTime

When the job was added to the queue.

started_at: Option<OffsetDateTime>

When the job’s last run started.

finished_at: Option<OffsetDateTime>

When the job finished.

expires_at: Option<OffsetDateTime>

If currently running, when the job will time out.

run_info: SmallVec<[RunInfo<Box<RawValue>>; 4]>

Information about each run of the job.

Trait Implementations

impl Debug for JobStatus

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

Formats the value using the given formatter.