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
49
50
51

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

pub struct PollingActivities;

#[activities]
impl PollingActivities {
    #[activity]
    pub async fn check_condition(
        _ctx: ActivityContext,
        attempt: u32,
    ) -> Result<bool, ActivityError> {
        Ok(attempt >= 3)
    }
}

fn activity_opts() -> ActivityOptions {
    ActivityOptions::start_to_close_timeout(Duration::from_secs(10))
}

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

#[workflow_methods]
impl PollingWorkflow {
    #[run]
    pub async fn run(ctx: &mut WorkflowContext<Self>, max_attempts: u32) -> WorkflowResult<String> {
        for attempt in 1..=max_attempts {
            let is_ready = ctx
                .start_activity(PollingActivities::check_condition, attempt, activity_opts())
                .await
                .map_err(|e| anyhow::anyhow!("{e}"))?;

            if is_ready {
                return Ok(format!("Condition met on attempt {attempt}"));
            }

            if attempt < max_attempts {
                ctx.timer(Duration::from_secs(1)).await;
            }
        }

        Ok(format!("Condition not met after {max_attempts} attempts"))
    }
}