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
52
53
54

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

pub struct TimerActivities;

#[activities]
impl TimerActivities {
    #[activity]
    pub async fn slow_activity(
        _ctx: ActivityContext,
        delay_ms: u64,
    ) -> Result<String, ActivityError> {
        tokio::time::sleep(std::time::Duration::from_millis(delay_ms)).await;
        Ok("activity completed".to_string())
    }
}

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

#[workflow_methods]
impl TimerWorkflow {
    #[run]
    pub async fn run(ctx: &mut WorkflowContext<Self>) -> WorkflowResult<String> {
        ctx.timer(Duration::from_secs(1)).await;

        let winner = temporalio_sdk::workflows::select! {
            _ = ctx.timer(Duration::from_secs(10)) => "timer",
            result = ctx.start_activity(
                TimerActivities::slow_activity,
                100u64,
                ActivityOptions::start_to_close_timeout(Duration::from_secs(30)),
            ) => {
                result.map_err(|e| anyhow::anyhow!("{e}"))?;
                "activity"
            }
        };

        let timer_fut = ctx.timer(Duration::from_secs(600));
        timer_fut.cancel();
        let timer_result = timer_fut.await;
        let was_cancelled = timer_result == TimerResult::Cancelled;

        Ok(format!(
            "race_winner={winner}, timer_cancelled={was_cancelled}"
        ))
    }
}