Skip to content

Commit 5630d48

Browse files
committed
temporal sdk fix
missing WorkflowIdConflictPolicy
1 parent b44a9b8 commit 5630d48

File tree

1 file changed

+5
-1
lines changed
  • rustybits/smeeclient/src

1 file changed

+5
-1
lines changed

rustybits/smeeclient/src/lib.rs

+5-1
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,10 @@ use serde::{Deserialize, Serialize};
1616
use std::str::FromStr;
1717
use std::time::Duration;
1818
use temporal_client::{Client, ClientOptionsBuilder, RetryClient, WorkflowClientTrait, WorkflowOptions};
19-
use temporal_sdk_core_protos::{coresdk::AsJsonPayloadExt, temporal::api::enums::v1::WorkflowIdReusePolicy};
19+
use temporal_sdk_core_protos::{
20+
coresdk::AsJsonPayloadExt,
21+
temporal::api::enums::v1::{WorkflowIdConflictPolicy, WorkflowIdReusePolicy},
22+
};
2023
use url::Url;
2124
use uuid::Uuid;
2225

@@ -72,6 +75,7 @@ impl SmeeClient {
7275
println!("notifying network joined");
7376
let options = WorkflowOptions {
7477
id_reuse_policy: WorkflowIdReusePolicy::RejectDuplicate,
78+
id_conflict_policy: WorkflowIdConflictPolicy::Fail,
7579
execution_timeout: None,
7680
run_timeout: None,
7781
task_timeout: None,

0 commit comments

Comments
 (0)