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
46
47
48
49
50
51
52
53
54

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

use graphile_worker_job::Job;
use graphile_worker_lifecycle_hooks::JobCompleteContext;

use crate::batcher::CompletionRequest;
use graphile_worker_queries::complete_job::complete_job;

use super::super::errors::ReleaseJobError;
use super::super::WorkerRunner;

pub(super) async fn release_completed_job(
    job: Arc<Job>,
    worker: &WorkerRunner,
    duration: Duration,
) -> Result<(), ReleaseJobError> {
    if let Some(batcher) = &worker.completion_batcher {
        batcher
            .complete(CompletionRequest {
                job_id: *job.id(),
                has_queue: job.job_queue_id().is_some(),
                job,
                duration,
            })
            .await;
        return Ok(());
    }

    complete_job(&worker.database, &job, &worker.worker_id, &worker.schema)
        .await
        .map_err(|source| ReleaseJobError {
            job_id: *job.id(),
            source,
        })?;

    emit_completion_hook(job, worker, duration).await;
    Ok(())
}

async fn emit_completion_hook(job: Arc<Job>, worker: &WorkerRunner, duration: Duration) {
    if worker.hooks.is_empty() {
        return;
    }

    worker
        .hooks
        .emit(JobCompleteContext {
            job,
            worker_id: worker.worker_id.clone(),
            duration,
        })
        .await;
}