feat(orchestration): increase start to close timeout

formancehq · Jul 17, 2024 · a72310c · a72310c
1 parent 902132f
commit a72310c
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 12 deletions.
diff --git a/ee/orchestration/cmd/root.go b/ee/orchestration/cmd/root.go
@@ -41,20 +41,20 @@ var (
 )
 
 const (
-	stackFlag                      = "stack"
-	stackURLFlag                   = "stack-url"
-	stackClientIDFlag              = "stack-client-id"
-	stackClientSecretFlag          = "stack-client-secret"
-	temporalAddressFlag            = "temporal-address"
-	temporalNamespaceFlag          = "temporal-namespace"
-	temporalSSLClientKeyFlag       = "temporal-ssl-client-key"
-	temporalSSLClientCertFlag      = "temporal-ssl-client-cert"
-	temporalTaskQueueFlag          = "temporal-task-queue"
+	stackFlag                     = "stack"
+	stackURLFlag                  = "stack-url"
+	stackClientIDFlag             = "stack-client-id"
+	stackClientSecretFlag         = "stack-client-secret"
+	temporalAddressFlag           = "temporal-address"
+	temporalNamespaceFlag         = "temporal-namespace"
+	temporalSSLClientKeyFlag      = "temporal-ssl-client-key"
+	temporalSSLClientCertFlag     = "temporal-ssl-client-cert"
+	temporalTaskQueueFlag         = "temporal-task-queue"
 	temporalInitSearchAttributes  = "temporal-init-search-attributes"
 	temporalMaxParallelActivities = "temporal-max-parallel-activities"
 	topicsFlag                    = "topics"
-	listenFlag                     = "listen"
-	workerFlag                     = "worker"
+	listenFlag                    = "listen"
+	workerFlag                    = "worker"
 )
 
 func NewRootCommand() *cobra.Command {

diff --git a/ee/orchestration/internal/workflow/stages/internal/context.go b/ee/orchestration/internal/workflow/stages/internal/context.go
@@ -16,7 +16,7 @@ const (
 
 func InfiniteRetryContext(ctx workflow.Context) workflow.Context {
 	return workflow.WithActivityOptions(ctx, workflow.ActivityOptions{
-		StartToCloseTimeout: 10 * time.Second,
+		StartToCloseTimeout: 60 * time.Second,
 		RetryPolicy: &temporal.RetryPolicy{
 			InitialInterval:    time.Second,
 			BackoffCoefficient: 2,