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
55
56

use super::*;

#[tokio::test]
async fn test_job_panics_are_recorded_as_failures() {
    #[derive(Serialize, Deserialize)]
    struct PanicJob {
        message: String,
    }

    impl TaskHandler for PanicJob {
        const IDENTIFIER: &'static str = "panic_job";

        async fn run(self, _ctx: WorkerContext) -> impl IntoTaskHandlerResult {
            if self.message.is_empty() {
                return Ok::<(), String>(());
            }

            panic!("{}", self.message);
        }
    }

    helpers::with_test_db(|test_db| async move {
        let worker = test_db
            .create_worker_options()
            .define_job::<PanicJob>()
            .init()
            .await
            .expect("Failed to create worker");

        let utils = worker.create_utils();
        utils
            .add_job(
                PanicJob {
                    message: "panic payload".to_string(),
                },
                JobSpecBuilder::new().max_attempts(3).build(),
            )
            .await
            .expect("Failed to add job");

        worker.run_once().await.expect("Failed to run worker");

        let jobs = test_db.get_jobs().await;
        assert_eq!(jobs.len(), 1, "Job should still be in the database");
        let job = &jobs[0];
        assert_eq!(job.task_identifier, "panic_job");
        assert_eq!(job.attempts, 1, "Job should have one failed attempt");
        assert!(
            job.last_error
                .as_ref()
                .is_some_and(|error| error.contains("panic payload")),
            "Error message should contain the panic payload"
        );
    })
    .await;
}