From 101759c4e028771892c3fe7948d5ea88ccbc21a3 Mon Sep 17 00:00:00 2001 From: Amogh-Bharadwaj <amogh@peerdb.io> Date: Thu, 28 Sep 2023 21:29:51 +0530 Subject: [PATCH] fix attempt: cdc test --- flow/connectors/postgres/postgres_cdc_test.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flow/connectors/postgres/postgres_cdc_test.go b/flow/connectors/postgres/postgres_cdc_test.go index ddc9dc3d82..e320ff690a 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() {