Skip to content

Commit

Permalink
Revert "fix attempt: cdc test"
Browse files Browse the repository at this point in the history
This reverts commit 101759c.
  • Loading branch information
Amogh-Bharadwaj committed Sep 28, 2023
1 parent 101759c commit 954d62d
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion flow/connectors/postgres/postgres_cdc_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -437,6 +437,7 @@ 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,
Expand All @@ -453,7 +454,6 @@ func (suite *PostgresCDCTestSuite) TestErrorForTableNotExist() {

err = suite.connector.PullFlowCleanup(nonExistentFlowName)
suite.failTestError(err)
suite.dropTable(nonExistentFlowSrcTableName)
}

func (suite *PostgresCDCTestSuite) TestSimpleHappyFlow() {
Expand Down

0 comments on commit 954d62d

Please sign in to comment.