durable-workflow 2.0.0

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
31
32
33
34
35

use std::time::Duration;

use durable_workflow::{
    json, wait_condition, Client, ConditionWaitResult, Result, SearchAttributeUpdate, Worker,
};

#[tokio::main]
async fn main() -> Result<()> {
    let client = Client::new("http://127.0.0.1:8080")?;
    let mut worker = Worker::new(client, "approval-workers");

    worker.register_workflow("approve-order", |ctx, _input| async move {
        let predicate_ctx = ctx.clone();
        let outcome = wait_condition!(
            ctx,
            "approval-received",
            timeout: Duration::from_secs(300),
            move || Ok(!predicate_ctx.signals("approve")?.is_empty()),
        )
        .await?;

        let status = match outcome {
            ConditionWaitResult::Satisfied => "approved",
            ConditionWaitResult::TimedOut => "approval_timed_out",
        };
        let attributes = SearchAttributeUpdate::new()
            .keyword("OrderStatus", status)?
            .bool("NeedsAttention", outcome.is_timed_out())?;
        ctx.upsert_search_attributes(attributes)?;

        Ok(json!({"status": status}))
    });

    worker.run().await
}