Struct prefect::RunningJob

pub struct RunningJob(pub Arc<RunningJobData>);

Information about a running job.

Tuple Fields

0: Arc<RunningJobData>

Methods from Deref<Target = 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, Error>

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 Clone for RunningJob

fn clone(&self) -> RunningJob

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for RunningJob

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

Formats the value using the given formatter.

impl Deref for RunningJob

type Target = RunningJobData

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl Display for RunningJob

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

Formats the value using the given formatter.