trying to see why tests are failing

PeerDB-io · Dec 6, 2023 · 04c5f24 · 04c5f24
1 parent 74af1b8
commit 04c5f24
Show file tree

Hide file tree

Showing 5 changed files with 5 additions and 5 deletions.
diff --git 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
@@ -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
@@ -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
@@ -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
@@ -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