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

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

#[tokio::test]
async fn sch_next() {
    let scher = Scheduler::new();
    let text = include_str!("./simple.yml");
    let workflow = Workflow::from_str(text).unwrap();

    let s = scher.clone();
    tokio::spawn(async move {
        s.push(&workflow);
    });

    let ret = scher.next().await;
    assert_eq!(ret, true);
}

#[tokio::test]
async fn sch_schedule_task() {
    let scher = Arc::new(Scheduler::new());

    let text = include_str!("./simple.yml");
    let workflow = Workflow::from_str(text).unwrap();

    let s = scher.clone();
    tokio::spawn(async move {
        let proc = Proc::new(s.clone(), &workflow, &TaskState::Pending);
        s.sched_proc(&proc)
    });

    let ret = scher.next().await;
    assert_eq!(ret, true);
}