IWF-119: Add workflowAlreadyStartedOptions (#258)

indeedeng · Oct 31, 2024 · c584c4a · c584c4a
1 parent 71172ee
commit c584c4a
Show file tree

Hide file tree

Showing 5 changed files with 13 additions and 1 deletion.
diff --git a/iwf-idl b/iwf-idl
diff --git a/src/main/java/io/iworkflow/core/Client.java b/src/main/java/io/iworkflow/core/Client.java
@@ -138,6 +138,7 @@ public String startWorkflow(
             unregisterWorkflowOptions.workflowConfigOverride(options.getWorkflowConfigOverride());
             unregisterWorkflowOptions.waitForCompletionStateExecutionIds(options.getWaitForCompletionStateExecutionIds());
             unregisterWorkflowOptions.waitForCompletionStateIds(options.getWaitForCompletionStateIds());
+            unregisterWorkflowOptions.workflowAlreadyStartedOptions(options.getWorkflowAlreadyStartedOptions());
 
             final Map<String, SearchAttributeValueType> saTypes = registry.getSearchAttributeKeyToTypeMap(wfType);
             final List<SearchAttribute> convertedSAs = convertToSearchAttributeList(saTypes, options.getInitialSearchAttribute());

diff --git a/src/main/java/io/iworkflow/core/UnregisteredClient.java b/src/main/java/io/iworkflow/core/UnregisteredClient.java
@@ -12,6 +12,7 @@
 import io.iworkflow.gen.models.PersistenceLoadingPolicy;
 import io.iworkflow.gen.models.SearchAttributeKeyAndType;
 import io.iworkflow.gen.models.StateCompletionOutput;
+import io.iworkflow.gen.models.WorkflowAlreadyStartedOptions;
 import io.iworkflow.gen.models.WorkflowGetDataObjectsRequest;
 import io.iworkflow.gen.models.WorkflowGetDataObjectsResponse;
 import io.iworkflow.gen.models.WorkflowGetRequest;
@@ -170,6 +171,10 @@ public String startWorkflow(
                 startOptions.useMemoForDataAttributes(options.getUsingMemoForDataAttributes().get());
             }
 
+            if (options.getWorkflowAlreadyStartedOptions().isPresent()) {
+                startOptions.workflowAlreadyStartedOptions(options.getWorkflowAlreadyStartedOptions().get());
+            }
+
             request.workflowStartOptions(startOptions);
 
             request.waitForCompletionStateExecutionIds(options.getWaitForCompletionStateExecutionIds());

diff --git a/src/main/java/io/iworkflow/core/UnregisteredWorkflowOptions.java b/src/main/java/io/iworkflow/core/UnregisteredWorkflowOptions.java
@@ -2,6 +2,7 @@
 
 import io.iworkflow.gen.models.IDReusePolicy;
 import io.iworkflow.gen.models.SearchAttribute;
+import io.iworkflow.gen.models.WorkflowAlreadyStartedOptions;
 import io.iworkflow.gen.models.WorkflowConfig;
 import io.iworkflow.gen.models.WorkflowRetryPolicy;
 import io.iworkflow.gen.models.WorkflowStateOptions;
@@ -31,4 +32,6 @@ public abstract class UnregisteredWorkflowOptions {
     public abstract List<String> getWaitForCompletionStateExecutionIds();
 
     public abstract List<String> getWaitForCompletionStateIds();
+
+    public abstract Optional<WorkflowAlreadyStartedOptions> getWorkflowAlreadyStartedOptions();
 }
diff --git a/src/main/java/io/iworkflow/core/WorkflowOptions.java b/src/main/java/io/iworkflow/core/WorkflowOptions.java
@@ -1,6 +1,7 @@
 package io.iworkflow.core;
 
 import io.iworkflow.gen.models.IDReusePolicy;
+import io.iworkflow.gen.models.WorkflowAlreadyStartedOptions;
 import io.iworkflow.gen.models.WorkflowConfig;
 import io.iworkflow.gen.models.WorkflowRetryPolicy;
 import org.immutables.value.Value;
@@ -26,6 +27,8 @@ public abstract class WorkflowOptions {
     public abstract List<String> getWaitForCompletionStateIds();
     public abstract List<String> getWaitForCompletionStateExecutionIds();
 
+    public abstract Optional<WorkflowAlreadyStartedOptions> getWorkflowAlreadyStartedOptions();
+
     public static WorkflowOptionBuilderExtension extendedBuilder() {
         return new WorkflowOptionBuilderExtension();
     }