Struct prefect::RunningJobData

pub struct RunningJobData {
    pub id: Uuid,
    pub worker_id: u64,
    pub heartbeat_increment: i32,
    pub job_type: String,
    pub priority: i32,
    pub weight: u16,
    pub payload: Vec<u8>,
    pub expires: AtomicI64,
    pub start_time: OffsetDateTime,
    pub current_try: i32,
    pub max_retries: i32,
    /* private fields */
}

Information about a running job. This is usually accessed through the RunningJob type, which wraps this in an Arc.

Fields

id: Uuid

The id of this job.

worker_id: u64

The ID of the Worker that is running this job.

heartbeat_increment: i32

How many seconds a heartbeat can extend the expiration time.

job_type: String

The type of the job.

priority: i32

The job’s priority.

weight: u16

How much this job counts against the worker’s concurrency limit.

payload: Vec<u8>

The payload of the job. JSON payloads can be parsed using the RunningJobData::json_payload function.

expires: AtomicI64

The timestamp, in seconds, when this job expires.

start_time: OffsetDateTime

When the job was started.

current_try: i32

How many times this job has been tried already. On the first run, this will be 0.

max_retries: i32

The number of times this job can be retried before giving up permanently.

Implementations

impl RunningJobData

pub async fn checkpoint_blob(
    &self,
    new_payload: Vec<u8>
) -> Result<OffsetDateTime>

Checkpoint the task, replacing the payload with the passed in value.

pub async fn checkpoint_json<T: Serialize>(
    &self,
    new_payload: T
) -> Result<OffsetDateTime>

Checkpoint the task, replacing the payload with the passed in value.

pub async fn heartbeat(&self) -> Result<OffsetDateTime>

Tell the queue that the task is still running.

pub fn is_expired(&self) -> bool

Return if the task is past the expiration time or not.

pub fn json_payload<'a, T: Deserialize<'a>>(&'a self) -> Result<T>

Deserialize a JSON payload into the requested type.

pub async fn complete<T: Serialize + Send + Debug>(
    &self,
    info: T
) -> Result<(), Error>

Mark the job as successful.

pub async fn fail<T: Serialize + Send + Debug>(
    &self,
    info: T
) -> Result<(), Error>

Mark the job as failed.

Trait Implementations

impl Debug for RunningJobData

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

Formats the value using the given formatter.

impl Display for RunningJobData

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

Formats the value using the given formatter.