Struct FailedJob 

pub struct FailedJob {
    pub id: i32,
    pub job_id: i32,
    pub payload: String,
    pub attempts: i32,
    pub reason: String,
    pub failed_at: NaiveDateTime,
}

Represents a failed job record in the database.

Corresponds to the failed_jobs table in the database, and stores information about jobs that have failed execution.

Fields

• id: Primary key of the failed job record.
• job_id: The original id of the failed job from the jobs table.
• payload: The serialized data for the job (e.g. parameters or settings).
• attempts: Number of attempts that were made to run the job.
• reason: Description or reason why the job failed.
• failed_at: Timestamp (UTC or local) of when the job failed.

Fields

id: i32

job_id: i32

payload: String

attempts: i32

reason: String

failed_at: NaiveDateTime

Implementations

impl FailedJob

pub fn create(job: &Job, _reason: &str) -> Result<(), Error>

Creates a new record in the failed_jobs table based on a failed Job.

This function:

1. Constructs a NewFailedJob using information from the provided Job.
2. Attempts to obtain a database connection via DB::get_conn.
3. Inserts the new record into the failed_jobs table using Diesel.

Parameters

• job: The job that failed, containing its ID, payload, and attempt count.
• _reason: A string that describes the reason for the failure.

Returns

• Ok(()) if the record was inserted successfully.
• Err(diesel::result::Error) if the operation fails (e.g. unable to get a DB connection or insert fails).

Errors

Returns diesel::result::Error::NotFound if a database connection cannot be acquired. Otherwise, returns a more specific Diesel error if the insert fails.

Example

// Pseudocode for handling a failed job:
use zirv_queue::models::job::Job;
use zirv_queue::models::failed_job::FailedJob;

// Suppose `some_failed_job` is an instance of `Job`
let some_failed_job = Job {
    id: 1,
    payload: "some payload".to_string(),
    attempts: 3,
    available_at: chrono::Local::now().naive_local(),
    created_at: chrono::Local::now().naive_local(),
    updated_at: chrono::Local::now().naive_local(),
    status: "failed".to_string(),
};

let reason = "Timed out.".to_string();

match FailedJob::create(some_failed_job, reason) {
    Ok(_) => println!("Failed job record inserted."),
    Err(e) => eprintln!("Error inserting failed job: {:?}", e),
}

Trait Implementations

impl Debug for FailedJob

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for FailedJob

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<'insert> Insertable<table> for &'insert FailedJob

type Values = <(Option<Grouped<Eq<id, <&'insert i32 as AsExpression<<id as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<job_id, <&'insert i32 as AsExpression<<job_id as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<payload, <&'insert String as AsExpression<<payload as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<attempts, <&'insert i32 as AsExpression<<attempts as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<reason, <&'insert String as AsExpression<<reason as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<failed_at, <&'insert NaiveDateTime as AsExpression<<failed_at as Expression>::SqlType>>::Expression>>>) as Insertable<table>>::Values

The VALUES clause to insert these records

fn values( self, ) -> <(Option<Eq<id, &'insert i32>>, Option<Eq<job_id, &'insert i32>>, Option<Eq<payload, &'insert String>>, Option<Eq<attempts, &'insert i32>>, Option<Eq<reason, &'insert String>>, Option<Eq<failed_at, &'insert NaiveDateTime>>) as Insertable<table>>::Values

Construct Self::Values

fn insert_into(self, table: T) -> InsertStatement<T, Self::Values>

where T: Table, Self: Sized,

Insert self into a given table.

impl Insertable<table> for FailedJob

type Values = <(Option<Grouped<Eq<id, <i32 as AsExpression<<id as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<job_id, <i32 as AsExpression<<job_id as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<payload, <String as AsExpression<<payload as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<attempts, <i32 as AsExpression<<attempts as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<reason, <String as AsExpression<<reason as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<failed_at, <NaiveDateTime as AsExpression<<failed_at as Expression>::SqlType>>::Expression>>>) as Insertable<table>>::Values

The VALUES clause to insert these records

fn values( self, ) -> <(Option<Eq<id, i32>>, Option<Eq<job_id, i32>>, Option<Eq<payload, String>>, Option<Eq<attempts, i32>>, Option<Eq<reason, String>>, Option<Eq<failed_at, NaiveDateTime>>) as Insertable<table>>::Values

Construct Self::Values

fn insert_into(self, table: T) -> InsertStatement<T, Self::Values>

where T: Table, Self: Sized,

Insert self into a given table.

impl<__DB: Backend, __ST0, __ST1, __ST2, __ST3, __ST4, __ST5> Queryable<(__ST0, __ST1, __ST2, __ST3, __ST4, __ST5), __DB> for FailedJob

where (i32, i32, String, i32, String, NaiveDateTime): FromStaticSqlRow<(__ST0, __ST1, __ST2, __ST3, __ST4, __ST5), __DB>,

type Row = (i32, i32, String, i32, String, NaiveDateTime)

The Rust type you’d like to map from.

fn build(row: (i32, i32, String, i32, String, NaiveDateTime)) -> Result<Self>

Construct an instance of this type

impl Serialize for FailedJob

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl UndecoratedInsertRecord<table> for FailedJob