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::TaskState, ActTask, Context, Workflow};
use async_trait::async_trait;
use core::clone::Clone;
use serde_yaml::Value;
use std::collections::HashMap;

impl_act_state!(Workflow);
impl_act_time!(Workflow);
impl_act_id!(Workflow);

impl Workflow {
    pub(in crate::sch) fn check_pass(&self, _ctx: &Context) -> bool {
        true
    }

    pub fn is_finished(&self) -> bool {
        if self.state().is_completed() {
            return true;
        }
        let mut ret = true;
        for job in &self.jobs {
            ret &= job.state().is_completed();
        }

        ret
    }

    pub fn set_outputs(&self, inputs: HashMap<String, Value>) {
        let mut outputs = self.share_outputs.write().unwrap();
        *outputs = inputs;
    }
}

#[async_trait]
impl ActTask for Workflow {
    fn run(&self, _ctx: &Context) {}
}