graphile_worker 0.13.3

High performance Rust/PostgreSQL job queue (also suitable for getting jobs generated by PostgreSQL triggers/functions out into a different work queue)
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45

use std::sync::Arc;
use std::time::Duration;

use graphile_worker_job::Job;
use graphile_worker_lifecycle_hooks::{FailureReason, JobInterruptedContext};
use graphile_worker_recovery::{apply_job_recovery, JobRecoveryRequest};

use super::{ReleaseJobError, WorkerRunner};

pub(super) async fn recover_shutdown_aborted_job(
    worker: &WorkerRunner,
    job: Arc<Job>,
    recovery_delay: Duration,
) -> Result<(), ReleaseJobError> {
    let outcome = apply_job_recovery(
        &worker.database,
        &worker.schema,
        JobRecoveryRequest {
            hooks: Some(&worker.hooks),
            worker_id: &worker.worker_id,
            job: job.clone(),
            previous_worker_id: &worker.worker_id,
            reason: FailureReason::ShutdownAborted,
            recovery_delay,
        },
    )
    .await
    .map_err(|source| ReleaseJobError {
        job_id: *job.id(),
        source,
    })?;

    if outcome.was_handled() && !worker.hooks.is_empty() {
        worker
            .hooks
            .emit(JobInterruptedContext {
                job,
                worker_id: worker.worker_id.clone(),
                reason: FailureReason::ShutdownAborted,
            })
            .await;
    }

    Ok(())
}