dex-sdk 1.38.0

Strongly typed Rust SDK for Dex
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
55
56
57
58
59

// Portions of this file are derived from indeedeng/iwf-java-sdk.
// Those portions are licensed under the Apache License, Version 2.0.
// See LICENSES/Apache-2.0.txt and LEGACY_NOTICES.md.
//
// Modifications Copyright (c) 2026 Super Durable, Inc.
//
// Modifications are licensed under the Sustainable Use License 1.0.
// Third-Party Materials remain under the Apache License, Version 2.0.
// See LICENSE and LEGACY_NOTICES.md.

use std::time::Duration;

use dex_sdk::{Registry, Step};

use crate::multi_output_workflow::MultiOutputWorkflow;
use crate::support::{DexDevTestEnvironment, flow_id};

#[test]
#[ignore = "requires dexcli dev"]
fn parallel_branches_return_heterogeneous_step_completions() {
    let environment =
        DexDevTestEnvironment::start(Registry::new().register(MultiOutputWorkflow::new()));
    let workflow = MultiOutputWorkflow::new();
    let flow_id = flow_id("multi-output");
    environment
        .client
        .start_flow(&workflow, &flow_id, ())
        .expect("start multi-output Flow");
    let result = environment
        .client
        .wait_for_flow_with_timeout(&flow_id, Duration::from_secs(30))
        .expect("wait for multi-output Flow");

    assert_eq!(result.completions().len(), 2);
    let string_completion = result
        .completions()
        .iter()
        .find(|completion| completion.step_type == workflow.string_step.step_type())
        .expect("string completion");
    assert_eq!(
        string_completion.decode::<String>().expect("decode string"),
        "branch-one"
    );
    let integer_completion = result
        .completions()
        .iter()
        .find(|completion| completion.step_type == workflow.integer_step.step_type())
        .expect("integer completion");
    assert_eq!(
        integer_completion.decode::<i32>().expect("decode integer"),
        42
    );
    assert!(
        result
            .completions()
            .iter()
            .all(|completion| !completion.step_execution_id.is_empty())
    );
}