diff --git a/flow/workflows/setup_flow.go b/flow/workflows/setup_flow.go
index c4ffab683..131a04a1e 100644
--- a/flow/workflows/setup_flow.go
+++ b/flow/workflows/setup_flow.go
@@ -108,7 +108,7 @@ func (s *SetupFlowExecution) ensurePullability(
 	s.logger.Info("ensuring pullability for peer flow - ", s.cdcFlowName)
 
 	ctx = workflow.WithActivityOptions(ctx, workflow.ActivityOptions{
-		StartToCloseTimeout: 1 * time.Hour,
+		StartToCloseTimeout: 4 * time.Hour,
 	})
 	srcTableIdNameMapping := make(map[uint32]string)