|
@@ -16,7 +16,10 @@ use serde::{Deserialize, Serialize};
|
|
|
use std::str::FromStr;
|
|
|
use std::time::Duration;
|
|
|
use temporal_client::{Client, ClientOptionsBuilder, RetryClient, WorkflowClientTrait, WorkflowOptions};
|
|
|
-use temporal_sdk_core_protos::{coresdk::AsJsonPayloadExt, temporal::api::enums::v1::WorkflowIdReusePolicy};
|
|
|
+use temporal_sdk_core_protos::{
|
|
|
+ coresdk::AsJsonPayloadExt,
|
|
|
+ temporal::api::enums::v1::{WorkflowIdConflictPolicy, WorkflowIdReusePolicy},
|
|
|
+};
|
|
|
use url::Url;
|
|
|
use uuid::Uuid;
|
|
|
|
|
@@ -72,6 +75,7 @@ impl SmeeClient {
|
|
|
println!("notifying network joined");
|
|
|
let options = WorkflowOptions {
|
|
|
id_reuse_policy: WorkflowIdReusePolicy::RejectDuplicate,
|
|
|
+ id_conflict_policy: WorkflowIdConflictPolicy::Fail,
|
|
|
execution_timeout: None,
|
|
|
run_timeout: None,
|
|
|
task_timeout: None,
|