temporalio-sdk 0.3.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

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

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

#[workflow_methods]
impl ContinueAsNewWorkflow {
    #[run]
    pub async fn run(ctx: &mut WorkflowContext<Self>, input: (u32, u32)) -> WorkflowResult<String> {
        let (current_iteration, max_iterations) = input;
        ctx.timer(Duration::from_millis(100)).await;

        if current_iteration < max_iterations {
            ctx.continue_as_new(
                &(current_iteration + 1, max_iterations),
                ContinueAsNewOptions::default(),
            )?;
        }

        Ok(format!("Completed after {max_iterations} iterations"))
    }
}