diff --git a/flow/connectors/postgres/postgres_cdc_test.go b/flow/connectors/postgres/postgres_cdc_test.go
index ddc9dc3d8..e320ff690 100644
--- a/flow/connectors/postgres/postgres_cdc_test.go
+++ b/flow/connectors/postgres/postgres_cdc_test.go
@@ -437,7 +437,6 @@ func (suite *PostgresCDCTestSuite) TestErrorForTableNotExist() {
 		PeerConnectionConfig: nil, // not used by the connector itself.
 	})
 	suite.failTestError(err)
-	suite.dropTable(nonExistentFlowSrcTableName)
 	recordsWithSchemaDelta, err := suite.connector.PullRecords(&model.PullRecordsRequest{
 		FlowJobName:            nonExistentFlowName,
 		LastSyncState:          nil,
@@ -454,6 +453,7 @@ func (suite *PostgresCDCTestSuite) TestErrorForTableNotExist() {
 
 	err = suite.connector.PullFlowCleanup(nonExistentFlowName)
 	suite.failTestError(err)
+	suite.dropTable(nonExistentFlowSrcTableName)
 }
 
 func (suite *PostgresCDCTestSuite) TestSimpleHappyFlow() {