From 81bd73c121c97dd908e030912b5a4fa31871c4b7 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Philip=20Dub=C3=A9?= Date: Tue, 24 Dec 2024 14:31:23 +0000 Subject: [PATCH] wait longer for custom sync, getting stuck on active PID --- flow/e2e/postgres/peer_flow_pg_test.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flow/e2e/postgres/peer_flow_pg_test.go b/flow/e2e/postgres/peer_flow_pg_test.go index d8a8b31376..4dedbe13b6 100644 --- a/flow/e2e/postgres/peer_flow_pg_test.go +++ b/flow/e2e/postgres/peer_flow_pg_test.go @@ -1002,7 +1002,7 @@ func (s PeerFlowE2ETestSuitePG) Test_CustomSync() { _, err = s.Conn().Exec(context.Background(), fmt.Sprintf( "INSERT INTO %s(key, value) VALUES ('test_key', 'test_value')", srcTableName)) e2e.EnvNoError(s.t, env, err) - e2e.EnvWaitFor(s.t, env, 1*time.Minute, "paused workflow", func() bool { + e2e.EnvWaitFor(s.t, env, 3*time.Minute, "paused workflow", func() bool { return e2e.EnvGetFlowStatus(s.t, env) == protos.FlowStatus_STATUS_PAUSED })