diff --git a/flow/workflows/snapshot_flow.go b/flow/workflows/snapshot_flow.go index b5f080996c..39eafaf87c 100644 --- a/flow/workflows/snapshot_flow.go +++ b/flow/workflows/snapshot_flow.go @@ -34,7 +34,7 @@ func (s *SnapshotFlowExecution) setupReplication( s.logger.Info("setting up replication on source for peer flow - ", flowName) ctx = workflow.WithActivityOptions(ctx, workflow.ActivityOptions{ - StartToCloseTimeout: 15 * time.Minute, + StartToCloseTimeout: 4 * time.Hour, RetryPolicy: &temporal.RetryPolicy{ MaximumAttempts: 20, },