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

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

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

#[workflow_methods]
impl SearchAttributesWorkflow {
    #[run]
    pub async fn run(ctx: &mut WorkflowContext<Self>, _input: ()) -> WorkflowResult<String> {
        let initial_attrs = ctx.search_attributes();
        let initial_keyword = initial_attrs
            .indexed_fields
            .get("CustomKeywordField")
            .and_then(|p| serde_json::from_slice::<String>(&p.data).ok())
            .unwrap_or_default();

        ctx.upsert_search_attributes([
            (
                "CustomKeywordField".to_string(),
                "updated-value".as_json_payload().unwrap(),
            ),
            (
                "CustomIntField".to_string(),
                42i64.as_json_payload().unwrap(),
            ),
        ]);

        Ok(format!(
            "initial_keyword={initial_keyword}, upserted CustomIntField=42"
        ))
    }
}