celery 0.1.0-alpha

Rust implementation of Celery
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

use async_trait::async_trait;
use serde::{Deserialize, Serialize};

use crate::error::Error;

/// A `Task` represents a unit of work that a `Celery` app can produce or consume.
#[async_trait]
pub trait Task: Send + Sync + Serialize + for<'de> Deserialize<'de> {
    type Returns: Send + Sync;

    async fn run(&mut self) -> Result<Self::Returns, Error>;

    async fn on_failure(&mut self, err: Error) -> Result<(), Error> {
        Err(err)
    }

    #[allow(unused_variables)]
    async fn on_success(&mut self, returned: Self::Returns) -> Result<(), Error> {
        Ok(())
    }

    fn timeout(&self) -> Option<usize> {
        None
    }

    fn max_retries(&self) -> Option<usize> {
        None
    }

    fn min_retry_delay(&self) -> usize {
        0
    }

    fn max_retry_delay(&self) -> usize {
        3600
    }
}