workflow-graph-worker-sdk 0.6.7

Worker SDK and binary for executing workflow-graph jobs
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

use workflow_graph_worker_sdk::{Worker, WorkerConfig};

#[tokio::main]
async fn main() {
    let server_url = std::env::var("SERVER_URL").unwrap_or_else(|_| "http://localhost:3000".into());

    let labels: Vec<String> = std::env::var("WORKER_LABELS")
        .unwrap_or_default()
        .split(',')
        .filter(|s| !s.is_empty())
        .map(|s| s.trim().to_string())
        .collect();

    println!("Staring on {} ...", &server_url);

    let config = WorkerConfig {
        server_url,
        labels,
        ..Default::default()
    };

    println!("Starting worker {} ...", config.worker_id);

    let worker = Worker::new(config);
    if let Err(e) = worker.run().await {
        eprintln!("Worker failed: {e}");
        std::process::exit(1);
    }
}