From 04c5f2456861de2ca4f453e055e269dc23677836 Mon Sep 17 00:00:00 2001 From: Kevin Biju Date: Wed, 6 Dec 2023 12:16:45 +0530 Subject: [PATCH] trying to see why tests are failing --- flow/e2e/bigquery/peer_flow_bq_test.go | 2 +- flow/e2e/postgres/qrep_flow_pg_test.go | 2 +- flow/e2e/s3/qrep_flow_s3_test.go | 2 +- flow/e2e/snowflake/peer_flow_sf_test.go | 2 +- flow/e2e/sqlserver/qrep_flow_sqlserver_test.go | 2 +- 5 files changed, 5 insertions(+), 5 deletions(-) diff --git a/flow/e2e/bigquery/peer_flow_bq_test.go b/flow/e2e/bigquery/peer_flow_bq_test.go index ba8c2cb54c..2a287b5781 100644 --- a/flow/e2e/bigquery/peer_flow_bq_test.go +++ b/flow/e2e/bigquery/peer_flow_bq_test.go @@ -81,7 +81,7 @@ func (s *PeerFlowE2ETestSuiteBQ) SetupSuite() { tsSuffix := time.Now().Format("20060102150405") s.bqSuffix = fmt.Sprintf("bq_%s_%s", strings.ToLower(suffix), tsSuffix) pool, err := e2e.SetupPostgres(s.bqSuffix) - if err != nil { + if err != nil || pool == nil { s.Fail("failed to setup postgres", err) } s.pool = pool diff --git a/flow/e2e/postgres/qrep_flow_pg_test.go b/flow/e2e/postgres/qrep_flow_pg_test.go index f8658a9825..5326a58e3d 100644 --- a/flow/e2e/postgres/qrep_flow_pg_test.go +++ b/flow/e2e/postgres/qrep_flow_pg_test.go @@ -43,7 +43,7 @@ func (s *PeerFlowE2ETestSuitePG) SetupSuite() { log.SetReportCaller(true) pool, err := e2e.SetupPostgres(postgresSuffix) - if err != nil { + if err != nil || pool == nil { s.Fail("failed to setup postgres", err) } s.pool = pool diff --git a/flow/e2e/s3/qrep_flow_s3_test.go b/flow/e2e/s3/qrep_flow_s3_test.go index d053e14372..d807cf6335 100644 --- a/flow/e2e/s3/qrep_flow_s3_test.go +++ b/flow/e2e/s3/qrep_flow_s3_test.go @@ -61,7 +61,7 @@ func (s *PeerFlowE2ETestSuiteS3) SetupSuite() { log.SetReportCaller(true) pool, err := e2e.SetupPostgres(s3Suffix) - if err != nil { + if err != nil || pool == nil { s.Fail("failed to setup postgres", err) } s.pool = pool diff --git a/flow/e2e/snowflake/peer_flow_sf_test.go b/flow/e2e/snowflake/peer_flow_sf_test.go index a06ca8d8b8..65b98fdb2d 100644 --- a/flow/e2e/snowflake/peer_flow_sf_test.go +++ b/flow/e2e/snowflake/peer_flow_sf_test.go @@ -89,7 +89,7 @@ func (s *PeerFlowE2ETestSuiteSF) SetupSuite() { s.pgSuffix = fmt.Sprintf("sf_%s_%s", strings.ToLower(suffix), tsSuffix) pool, err := e2e.SetupPostgres(s.pgSuffix) - if err != nil { + if err != nil || pool == nil { s.Fail("failed to setup postgres", err) } s.pool = pool diff --git a/flow/e2e/sqlserver/qrep_flow_sqlserver_test.go b/flow/e2e/sqlserver/qrep_flow_sqlserver_test.go index dbc48e577d..c3a9f88034 100644 --- a/flow/e2e/sqlserver/qrep_flow_sqlserver_test.go +++ b/flow/e2e/sqlserver/qrep_flow_sqlserver_test.go @@ -57,7 +57,7 @@ func (s *PeerFlowE2ETestSuiteSQLServer) SetupSuite() { log.SetReportCaller(true) pool, err := e2e.SetupPostgres(sqlserverSuffix) - if err != nil { + if err != nil || pool == nil { s.Fail("failed to setup postgres", err) } s.pool = pool