diff --git a/flow/e2e/congen.go b/flow/e2e/congen.go
index cce1f5fef6..c063b9a174 100644
--- 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
index 0d84e35b82..5b9b53ea87 100644
--- 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 {