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

use clap::Parser;
use std::{fs::File, io::Read};
use yao::{Engine, Workflow};

#[derive(Parser, Debug)]
#[clap(author, version, about)]
struct Args {
    #[clap(short, long, value_parser)]
    model: String,
}

#[tokio::main]
async fn main() {
    let args = Args::parse();

    let workflow = read_file_to_workflow(&args.model);
    let engine = Engine::new();
    engine.push(&workflow);

    let e = engine.clone();
    engine.on_workflow_complete(move |_w: &Workflow| {
        e.close();
    });
    engine.start().await;
}

fn read_file_to_workflow(file_name: &str) -> Workflow {
    let mut file = File::open(file_name).expect("Invalid config file");
    let mut config_value = String::new();
    file.read_to_string(&mut config_value)
        .expect("Read config file error");
    let workflow: Workflow = serde_yaml::from_str(&config_value).expect("Parse yaml error");

    workflow
}