kafru 1.0.4

kafru is a Python Celery-inspired queuing library for Rust, using cron for scheduling and SurrealDB for storing queues, metrics, and schedules.
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


#[cfg(test)]
mod test_task_handler {
    use async_trait::async_trait;
    use crate::task::{
        TaskHandler,
        TaskRegistry,
        RecordId,
    };
    use serde_json::Value;

    pub struct MyTestStructA;

    #[async_trait]
    impl TaskHandler for MyTestStructA {
        async fn run(&self, _params: std::collections::HashMap<String,Value>, _queue_id: Option<RecordId>,  _agent_id: Option<RecordId>) -> Result<(),String> {
            Ok(())
        }
    }
    pub struct MyTestStructB;

    #[async_trait]
    impl TaskHandler for MyTestStructB {
        async fn run(&self, _params: std::collections::HashMap<String,Value>, _queue_id: Option<RecordId>,  _agent_id: Option<RecordId>) -> Result<(),String> {
            Ok(())
        }
    }

    #[tokio::test]
    async fn test(){
        let mut task_registry: TaskRegistry = TaskRegistry::new().await;
        assert!(task_registry.register("myteststructa".to_string(), || Box::new(MyTestStructA)).await);
        assert!(task_registry.register("myteststructb".to_string(), || Box::new(MyTestStructB)).await);
        assert!(task_registry.tasks().await.len() >0 );
    }
}