diff --git a/flow/workflows/setup_flow.go b/flow/workflows/setup_flow.go index 1ee4d4251..b1326d2a0 100644 --- a/flow/workflows/setup_flow.go +++ b/flow/workflows/setup_flow.go @@ -111,7 +111,7 @@ func (s *SetupFlowExecution) ensurePullability( s.Info("ensuring pullability for peer flow") ctx = workflow.WithActivityOptions(ctx, workflow.ActivityOptions{ - StartToCloseTimeout: 4 * time.Hour, + StartToCloseTimeout: 4 * 24 * time.Hour, RetryPolicy: &temporal.RetryPolicy{ InitialInterval: 1 * time.Minute, }, diff --git a/flow/workflows/snapshot_flow.go b/flow/workflows/snapshot_flow.go index 869819767..27614ffda 100644 --- a/flow/workflows/snapshot_flow.go +++ b/flow/workflows/snapshot_flow.go @@ -38,7 +38,7 @@ func (s *SnapshotFlowExecution) setupReplication( s.logger.Info("setting up replication on source for peer flow") ctx = workflow.WithActivityOptions(ctx, workflow.ActivityOptions{ - StartToCloseTimeout: 4 * time.Hour, + StartToCloseTimeout: 4 * 24 * time.Hour, RetryPolicy: &temporal.RetryPolicy{ InitialInterval: 1 * time.Minute, MaximumAttempts: 20,