add start delay

indeedeng · Mar 19, 2024 · 46f52ae · 46f52ae
1 parent fb332e5
commit 46f52ae
Show file tree

Hide file tree

Showing 4 changed files with 13 additions and 0 deletions.
diff --git a/service/api/cadence/client.go b/service/api/cadence/client.go
@@ -116,6 +116,10 @@ func (t *cadenceClient) StartInterpreterWorkflow(
 		workflowOptions.RetryPolicy = retry.ConvertCadenceWorkflowRetryPolicy(options.RetryPolicy)
 	}
 
+	if options.WorkflowStartDelay != nil {
+		workflowOptions.DelayStart = *options.WorkflowStartDelay
+	}
+
 	run, err := t.cClient.StartWorkflow(ctx, workflowOptions, cadence.Interpreter, args...)
 	if err != nil {
 		return "", err

diff --git a/service/api/service.go b/service/api/service.go
@@ -114,6 +114,10 @@ func (s *serviceImpl) ApiV1WorkflowStartPost(
 				Data: iwfidl.PtrString("true"),
 			}
 		}
+		if startOptions.WorkflowStartDelaySeconds != nil {
+			workflowOptions.WorkflowStartDelay =
+				ptr.Any(time.Duration(*startOptions.WorkflowStartDelaySeconds) * time.Second)
+		}
 	}
 
 	input := service.InterpreterWorkflowInput{

diff --git a/service/api/temporal/client.go b/service/api/temporal/client.go
@@ -142,6 +142,10 @@ func (t *temporalClient) StartInterpreterWorkflow(
 		return "", err
 	}
 
+	if options.WorkflowStartDelay != nil {
+		workflowOptions.StartDelay = *options.WorkflowStartDelay
+	}
+
 	run, err := t.tClient.ExecuteWorkflow(ctx, workflowOptions, temporal.Interpreter, args...)
 	if err != nil {
 		return "", err

diff --git a/service/client/interfaces.go b/service/client/interfaces.go
@@ -53,6 +53,7 @@ type StartWorkflowOptions struct {
 	RetryPolicy              *iwfidl.WorkflowRetryPolicy
 	SearchAttributes         map[string]interface{}
 	Memo                     map[string]interface{}
+	WorkflowStartDelay       *time.Duration
 }
 
 type ListWorkflowExecutionsRequest struct {