graphile_worker_utils 0.1.1

Worker utility helpers for graphile_worker
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

use graphile_worker_lifecycle_hooks::{BeforeJobScheduleContext, JobScheduleResult};

use graphile_worker_job_spec::JobSpec;
use graphile_worker_queries::errors::GraphileWorkerError;

use super::super::client::WorkerUtils;

pub(super) async fn invoke_before_job_schedule(
    utils: &WorkerUtils,
    identifier: &str,
    payload: serde_json::Value,
    spec: &JobSpec,
) -> Result<serde_json::Value, GraphileWorkerError> {
    let Some(hooks) = &utils.hooks else {
        return Ok(payload);
    };

    let ctx = BeforeJobScheduleContext {
        identifier: identifier.to_string(),
        payload,
        spec: spec.clone(),
    };

    match hooks.intercept(ctx).await {
        JobScheduleResult::Continue(payload) => Ok(payload),
        JobScheduleResult::Skip => Err(GraphileWorkerError::JobScheduleSkipped),
        JobScheduleResult::Fail(msg) => Err(GraphileWorkerError::JobScheduleFailed(msg)),
    }
}