acts 0.24.0

a fast, lightweight, 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

use crate::{
    ActTask, Result, TaskState, Workflow,
    scheduler::{Context, NextAction},
};

impl ActTask for Workflow {
    async fn init(&self, ctx: &Context) -> Result<()> {
        // init process env
        if !self.env.is_empty() {
            ctx.proc.with_env_mut(|data| {
                for var in self.env.iter() {
                    data.set(&var.name, var.value.clone());
                }
            });
        }

        Ok(())
    }

    async fn next(&self, ctx: &Context) -> Result<NextAction> {
        let task = ctx.task();

        if task.children().iter().all(|t| t.state().is_completed()) && task.state().is_running() {
            task.set_state(TaskState::Completed);
        }
        Ok(NextAction::Parent)
    }
}