Skip to content

Commit b9d5f37

Browse files
committed
fix generational rechecking test
1 parent 4ba0eda commit b9d5f37

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

internal/verifier/migration_verifier_test.go

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1390,6 +1390,12 @@ func (suite *IntegrationTestSuite) TestGenerationalRechecking() {
13901390
// there should be no failures now, since they are equivalent at this point in time
13911391
suite.Require().Equal(VerificationStatus{TotalTasks: 1, CompletedTasks: 1}, *status)
13921392

1393+
// The next generation should process the recheck task caused by inserting {_id: 2} on the destination.
1394+
suite.Require().NoError(runner.StartNextGeneration())
1395+
suite.Require().NoError(runner.AwaitGenerationEnd())
1396+
status = waitForTasks()
1397+
suite.Require().Equal(VerificationStatus{TotalTasks: 1, CompletedTasks: 1}, *status)
1398+
13931399
// now insert in the source, this should come up next generation
13941400
_, err = srcColl.InsertOne(ctx, bson.M{"_id": 3, "x": 44})
13951401
suite.Require().NoError(err)

0 commit comments

Comments
 (0)