temporalio-sdk 0.4.0

Temporal Rust SDK
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

#![allow(unreachable_pub)]
use temporalio_macros::{workflow, workflow_methods};
use temporalio_sdk::{ChildWorkflowOptions, WorkflowContext, WorkflowResult};

#[workflow]
#[derive(Default)]
pub struct GreetingChildWorkflow;

#[workflow_methods]
impl GreetingChildWorkflow {
    #[run(name = "GreetingChild")]
    pub async fn run(_ctx: &mut WorkflowContext<Self>, name: String) -> WorkflowResult<String> {
        Ok(format!("Hello, {name}!"))
    }
}

#[workflow]
#[derive(Default)]
pub struct ParentWorkflow;

#[workflow_methods]
impl ParentWorkflow {
    #[run]
    pub async fn run(
        ctx: &mut WorkflowContext<Self>,
        names: Vec<String>,
    ) -> WorkflowResult<Vec<String>> {
        let mut results = Vec::new();

        for (i, name) in names.iter().enumerate() {
            let started = ctx
                .child_workflow(
                    GreetingChildWorkflow::run,
                    name.clone(),
                    ChildWorkflowOptions {
                        workflow_id: format!("greeting-child-{i}"),
                        ..Default::default()
                    },
                )
                .await?;

            let greeting = started.result().await?;
            results.push(greeting);
        }

        Ok(results)
    }
}