swf-runtime 1.0.0-alpha9

Runtime engine for Serverless Workflow DSL — execute, validate, and orchestrate workflows
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

//! Secret manager example: use MapSecretManager to provide secrets to expressions.
//!
//! Run with: cargo run -p swf_runtime --example secret_workflow

use serde_json::json;
use std::sync::Arc;
use swf_core::models::workflow::WorkflowDefinition;
use swf_runtime::{MapSecretManager, WorkflowRunner};

#[tokio::main]
async fn main() {
    let yaml = r#"
document:
  dsl: '1.0.0'
  namespace: default
  name: secret-example
  version: '1.0.0'
do:
  - readSecret:
      set:
        user: ${ $secret.db.username }
"#;

    let workflow: WorkflowDefinition = serde_yaml::from_str(yaml).expect("failed to parse YAML");

    let secret_mgr = MapSecretManager::new()
        .with_secret("db", json!({ "username": "admin", "password": "s3cret" }));

    let runner = WorkflowRunner::new(workflow)
        .expect("failed to create runner")
        .with_secret_manager(Arc::new(secret_mgr));

    let result = runner
        .run(json!({}))
        .await
        .expect("workflow execution failed");

    println!("{}", serde_json::to_string_pretty(&result).unwrap());
}