Pulling my hair out trying to figure out why this pool is closed

PeerDB-io · Dec 22, 2023 · 325bb89 · 325bb89
1 parent b44c6a0
commit 325bb89
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 10 deletions.
diff --git a/flow/e2e/congen.go b/flow/e2e/congen.go
@@ -136,15 +136,8 @@ func SetupPostgres(suffix string) (*pgxpool.Pool, error) {
 }
 
 func TearDownPostgres(pool *pgxpool.Pool, suffix string) error {
-	// drop the e2e_test schema
-	if pool != nil {
-		err := cleanPostgres(pool, suffix)
-		if err != nil {
-			return err
-		}
-		pool.Close()
-	}
-	return nil
+	err := cleanPostgres(pool, suffix)
+	return err
 }
 
 // GeneratePostgresPeer generates a postgres peer config for testing.

diff --git a/flow/e2e/snowflake/peer_flow_sf_test.go b/flow/e2e/snowflake/peer_flow_sf_test.go
@@ -85,7 +85,6 @@ func setupSuite(t *testing.T) PeerFlowE2ETestSuiteSF {
 	return suite
 }
 
-// Implement TearDownAllSuite interface to tear down the test suite
 func (s PeerFlowE2ETestSuiteSF) TearDownSuite() {
 	err := e2e.TearDownPostgres(s.pool, s.pgSuffix)
 	if err != nil {