yao 0.1.4

a fast, tiny, extensiable workflow engine
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

use crate::{
    sch::{event::EventData, Proc, Scheduler},
    TaskState, Workflow,
};
use std::sync::Arc;

#[tokio::test]
async fn task_state() {
    let mut workflow = create_workflow();
    let (task, _) = create_proc(&mut workflow, "job1");
    assert!(task.state() == TaskState::None);
}

#[tokio::test]
async fn task_start() {
    let mut workflow = create_workflow();
    let (proc, scher) = create_proc(&mut workflow, "job1");

    proc.start();
    scher.on_proc(|proc: &Proc, _data: &EventData| {
        assert_eq!(proc.state(), TaskState::Running);
    });
}

fn create_proc(workflow: &mut Workflow, id: &str) -> (Proc, Arc<Scheduler>) {
    let scher = Scheduler::new();

    workflow.set_biz_id(id);
    let task = scher.create_raw_proc(workflow);

    (task.clone(), Arc::new(scher))
}

fn create_workflow() -> Workflow {
    let text = include_str!("./simple.yml");
    let workflow = Workflow::from_str(text).unwrap();
    workflow
}