From 88de2381b714c3831007081897fea067a1376efc Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Philip=20Dub=C3=A9?= Date: Tue, 5 Mar 2024 16:57:59 +0000 Subject: [PATCH] log --- flow/e2e/postgres/peer_flow_pg_test.go | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/flow/e2e/postgres/peer_flow_pg_test.go b/flow/e2e/postgres/peer_flow_pg_test.go index 4e003d59d1..64aa9cb6ba 100644 --- a/flow/e2e/postgres/peer_flow_pg_test.go +++ b/flow/e2e/postgres/peer_flow_pg_test.go @@ -1074,7 +1074,7 @@ func (s PeerFlowE2ETestSuitePG) Test_ContinueAsNew() { require.NoError(s.t, err) connectionGen := e2e.FlowConnectionGenerationConfig{ - FlowJobName: s.attachSuffix("test_simple_flow"), + FlowJobName: s.attachSuffix("test_continueasnew_flow"), TableNameMapping: map[string]string{srcTableName: dstTableName}, Destination: s.peer, } @@ -1097,7 +1097,12 @@ func (s PeerFlowE2ETestSuitePG) Test_ContinueAsNew() { s.t.Log("Inserted 180 rows into the source table") e2e.EnvWaitFor(s.t, env, 3*time.Minute, "normalize 90 syncs", func() bool { - return s.comparePGTables(srcTableName, dstTableName, "id,key,value") == nil + err := s.comparePGTables(srcTableName, dstTableName, "id,key,value") + if err != nil { + s.t.Log(err) + return false + } + return true }) env.Cancel()