diff --git a/flow/e2e/postgres/qrep_flow_pg_test.go b/flow/e2e/postgres/qrep_flow_pg_test.go index aa51b7d14f..ab651e5dfc 100644 --- a/flow/e2e/postgres/qrep_flow_pg_test.go +++ b/flow/e2e/postgres/qrep_flow_pg_test.go @@ -356,7 +356,7 @@ func (s PeerFlowE2ETestSuitePG) Test_Pause() { env := e2e.RunQrepFlowWorkflow(tc, config) e2e.SignalWorkflow(env, model.FlowSignal, model.PauseSignal) - e2e.EnvWaitFor(s.t, env, time.Minute, "pausing", func() bool { + e2e.EnvWaitFor(s.t, env, 3*time.Minute, "pausing", func() bool { response, err := env.Query(shared.QRepFlowStateQuery) if err != nil { s.t.Log(err)