actflow 0.1.6

A lightweight, event-driven workflow engine written in Rust.
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

use actflow::{ChannelEvent, ChannelOptions, EngineBuilder, WorkflowModel};

fn main() {
    let engine = EngineBuilder::new().build().unwrap();

    // Launch the engine
    engine.launch();

    let text = include_str!("./workflow.json");

    let workflow_model = WorkflowModel::from_json(text).unwrap();

    let process = engine.build_workflow_process(&workflow_model).unwrap();
    let pid = process.id();

    ChannelEvent::channel(engine.channel(), ChannelOptions::with_pid(pid.to_owned())).on_complete(move |pid| {
        println!("Workflow completed, pid: {}", pid);
    });

    ChannelEvent::channel(engine.channel(), ChannelOptions::with_pid(pid.to_owned())).on_error(move |e| {
        println!("Workflow failed: {:?}", e);
    });

    // Start the workflow process
    process.start();

    loop {
        if process.is_complete() {
            break;
        }
        std::thread::sleep(std::time::Duration::from_millis(100));
    }

    let outputs: serde_json::Value = process.get_outputs().into();
    println!("Outputs: {:#?}", outputs);
}