dag-flow 0.1.6

DAG Flow is a simple DAG workflow engine.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use std::collections::HashMap;

use crate::context::Value;

pub type Input<'a, T> = Value<'a, Option<T>>;

#[trait_variant::make(Send + Sync)]
#[dynosaur::dynosaur(pub(crate) DynTask = dyn(box) Task)]
pub trait Task<I, D> {
    fn id(&self) -> I;

    fn dependencies(&self) -> Vec<I> {
        Vec::new()
    }

    fn is_auto(&self) -> bool {
        true
    }

    async fn run(&self, inputs: HashMap<I, Input<'_, D>>) -> Option<D>;
}