durable-workflow 0.1.15

First-party Rust SDK for Durable Workflow workers and clients
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

use durable_workflow::{json, Client, ContinueAsNewOptions, Result, Value, Worker};

fn bounded_worker(client: Client) -> Worker {
    let mut worker = Worker::new(client, "batch-workers");
    worker.register_workflow("bounded-batch", |ctx, input| async move {
        let next = input.get(0).and_then(Value::as_u64).unwrap_or(0);
        let stop = input.get(1).and_then(Value::as_u64).unwrap_or(1_000);
        let chunk_end = next.saturating_add(100).min(stop);

        for item in next..chunk_end {
            ctx.activity("process-item", json!([item])).await?;
        }

        if chunk_end < stop {
            return ctx.continue_as_new_with_options(
                ContinueAsNewOptions::new().task_queue("batch-workers"),
                json!([chunk_end, stop]),
            );
        }

        Ok(json!({"processed": stop}))
    });
    worker
}

#[tokio::main]
async fn main() -> Result<()> {
    let client = Client::new("http://127.0.0.1:8080/api")?;
    bounded_worker(client).run().await
}