add start delay (#222)

indeedeng · Mar 22, 2024 · 71bc52d · 71bc52d
1 parent dc66ac7
commit 71bc52d
Show file tree

Hide file tree

Showing 6 changed files with 10 additions and 2 deletions.
diff --git a/build.gradle b/build.gradle
@@ -9,7 +9,7 @@
 plugins {
     // Apply the java-library plugin for API and implementation separation.
     id 'java-library'
-    id "org.openapi.generator" version "6.0.1"
+    id "org.openapi.generator" version "6.6.0"
     id 'org.springframework.boot' version '2.7.2'
     id 'io.spring.dependency-management' version '1.0.12.RELEASE'
     id 'io.github.gradle-nexus.publish-plugin' version '1.1.0'

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
@@ -134,6 +134,7 @@ public String startWorkflow(
         if (options != null) {
             unregisterWorkflowOptions.workflowIdReusePolicy(options.getWorkflowIdReusePolicy());
             unregisterWorkflowOptions.cronSchedule(options.getCronSchedule());
+            unregisterWorkflowOptions.workflowStartDelaySeconds(options.getWorkflowStartDelaySeconds());
             unregisterWorkflowOptions.workflowRetryPolicy(options.getWorkflowRetryPolicy());
             unregisterWorkflowOptions.workflowConfigOverride(options.getWorkflowConfigOverride());
             unregisterWorkflowOptions.waitForCompletionStateExecutionIds(options.getWaitForCompletionStateExecutionIds());

diff --git a/src/main/java/io/iworkflow/core/UnregisteredClient.java b/src/main/java/io/iworkflow/core/UnregisteredClient.java
@@ -141,6 +141,9 @@ public String startWorkflow(
             if (options.getCronSchedule().isPresent()) {
                 startOptions.cronSchedule(CronScheduleValidator.validate(options.getCronSchedule()));
             }
+            if (options.getWorkflowStartDelaySeconds().isPresent()) {
+                startOptions.workflowStartDelaySeconds(options.getWorkflowStartDelaySeconds().get());
+            }
             if (options.getWorkflowIdReusePolicy().isPresent()) {
                 startOptions.idReusePolicy(options.getWorkflowIdReusePolicy().get());
             }

diff --git a/src/main/java/io/iworkflow/core/UnregisteredWorkflowOptions.java b/src/main/java/io/iworkflow/core/UnregisteredWorkflowOptions.java
@@ -16,6 +16,8 @@ public abstract class UnregisteredWorkflowOptions {
 
     public abstract Optional<String> getCronSchedule();
 
+    public abstract Optional<Integer> getWorkflowStartDelaySeconds();
+
     public abstract Optional<WorkflowRetryPolicy> getWorkflowRetryPolicy();
 
     public abstract Optional<WorkflowStateOptions> getStartStateOptions();

diff --git a/src/main/java/io/iworkflow/core/WorkflowOptions.java b/src/main/java/io/iworkflow/core/WorkflowOptions.java
@@ -15,6 +15,8 @@ public abstract class WorkflowOptions {
 
     public abstract Optional<String> getCronSchedule();
 
+    public abstract Optional<Integer> getWorkflowStartDelaySeconds();
+
     public abstract Optional<WorkflowRetryPolicy> getWorkflowRetryPolicy();
 
     public abstract Map<String, Object> getInitialSearchAttribute();