apalis-sql 1.0.0-rc.7

SQL utilities for background job processing with apalis
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

use apalis_core::task::builder::TaskBuilder;

use crate::context::SqlContext;

/// Extension traits for [`TaskBuilder`]
pub trait TaskBuilderExt {
    /// Set the max number of attempts for the task being built.
    #[must_use]
    fn max_attempts(self, attempts: u32) -> Self;

    /// Set the priority for the task being built.
    #[must_use]
    fn priority(self, priority: i32) -> Self;
}

impl<Args, Pool, IdType> TaskBuilderExt for TaskBuilder<Args, SqlContext<Pool>, IdType> {
    fn max_attempts(mut self, attempts: u32) -> Self {
        self.ctx = self.ctx.with_max_attempts(attempts as i32);
        self
    }

    fn priority(mut self, priority: i32) -> Self {
        self.ctx = self.ctx.with_priority(priority);
        self
    }
}