Skip to content

Commit

Permalink
increae timeout
Browse files Browse the repository at this point in the history
  • Loading branch information
iskakaushik committed Mar 7, 2025
1 parent ff42813 commit 5cec94f
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion flow/workflows/setup_flow.go
Original file line number Diff line number Diff line change
Expand Up @@ -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,
},
Expand Down
2 changes: 1 addition & 1 deletion flow/workflows/snapshot_flow.go
Original file line number Diff line number Diff line change
Expand Up @@ -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,
Expand Down

0 comments on commit 5cec94f

Please # to comment.