runkon-flow 0.6.1-alpha

Portable workflow execution engine — DSL, traits, and in-memory reference implementations
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
37
38
39
40
41
42
43
44
45
46
47
48
49
50

use std::sync::Arc;

use runkon_flow::dsl::WorkflowDef;
use runkon_flow::engine_error::EngineError;
use runkon_flow::traits::workflow_resolver::WorkflowResolver;

/// `WorkflowResolver` that returns a single hard-coded `WorkflowDef` by name.
struct StaticWorkflowResolver {
    name: String,
    def: Arc<WorkflowDef>,
}

impl WorkflowResolver for StaticWorkflowResolver {
    fn resolve(&self, name: &str) -> Result<Arc<WorkflowDef>, EngineError> {
        if name == self.name {
            Ok(Arc::clone(&self.def))
        } else {
            Err(EngineError::WorkflowNotFound(name.to_string()))
        }
    }
}

fn main() {
    let dsl = r#"workflow hello {
  meta {
    description = "static resolver example"
    trigger     = "manual"
  }
  call my-agent
}"#;
    let def = runkon_flow::dsl::parse_workflow_str(dsl, "hello.wf").expect("DSL parse failed");

    let resolver = StaticWorkflowResolver {
        name: "hello".into(),
        def: Arc::new(def),
    };

    // Known name resolves successfully:
    match resolver.resolve("hello") {
        Ok(def) => println!("resolved '{}': {}", def.name, def.description),
        Err(e) => println!("error: {}", e),
    }

    // Unknown name returns WorkflowNotFound:
    match resolver.resolve("unknown") {
        Ok(_) => println!("unexpected success"),
        Err(EngineError::WorkflowNotFound(name)) => println!("not found: '{}'", name),
        Err(e) => println!("unexpected error: {}", e),
    }
}