pondrs 0.3.0

A pipeline execution library
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

//! Dynamic pipeline example using [`StepVec`].
//!
//! Demonstrates runtime step composition: the `report` node is only included
//! when the `include_report` param is `true`.
//!
//! Usage:
//!   cargo run --example dyn_steps_app -- run
//!   cargo run --example dyn_steps_app -- check

#[path = "dyn_steps/mod.rs"]
mod dyn_steps;

use dyn_steps::{pipeline, write_fixtures};
use pondrs::error::PondError;

// ANCHOR: app
fn main() -> Result<(), PondError> {
    let dir = {
        let manifest = std::path::Path::new(env!("CARGO_MANIFEST_DIR"));
        manifest.join("examples").join("dyn_steps_data")
    };
    write_fixtures(&dir);

    pondrs::app::App::from_yaml(
        dir.join("catalog.yml").to_str().unwrap(),
        dir.join("params.yml").to_str().unwrap(),
    )?
    .with_args(std::env::args_os())?
    .dispatch(pipeline)
}
// ANCHOR_END: app