@@ -1582,12 +1582,12 @@ func (suite *IntegrationTestSuite) TestChangesOnDstBeforeSrc() {
15821582 // Dry run generation 0 to make sure change stream reader is started.
15831583 suite .Require ().NoError (runner .AwaitGenerationEnd ())
15841584
1585- suite .Require ().NoError (runner .StartNextGeneration ())
15861585 // Insert two documents in generation 1. They should be batched and become a verify task in generation 2.
15871586 _ , err := dstDB .Collection (collName ).InsertOne (ctx , bson.D {{"_id" , 1 }})
15881587 suite .Require ().NoError (err )
15891588 _ , err = dstDB .Collection (collName ).InsertOne (ctx , bson.D {{"_id" , 2 }})
15901589 suite .Require ().NoError (err )
1590+ suite .Require ().NoError (runner .StartNextGeneration ())
15911591
15921592 suite .Require ().NoError (runner .AwaitGenerationEnd ())
15931593 suite .waitForRecheckDocs (verifier )
@@ -1603,9 +1603,10 @@ func (suite *IntegrationTestSuite) TestChangesOnDstBeforeSrc() {
16031603 )
16041604
16051605 // Patch up only one of the two mismatched documents in generation 3.
1606- suite .Require ().NoError (runner .StartNextGeneration ())
16071606 _ , err = srcDB .Collection (collName ).InsertOne (ctx , bson.D {{"_id" , 1 }})
16081607 suite .Require ().NoError (err )
1608+
1609+ suite .Require ().NoError (runner .StartNextGeneration ())
16091610 suite .Require ().NoError (runner .AwaitGenerationEnd ())
16101611 suite .waitForRecheckDocs (verifier )
16111612
@@ -1617,9 +1618,9 @@ func (suite *IntegrationTestSuite) TestChangesOnDstBeforeSrc() {
16171618 )
16181619
16191620 // Patch up both of the 2 mismatched documents in generation 4.
1620- suite .Require ().NoError (runner .StartNextGeneration ())
16211621 _ , err = srcDB .Collection (collName ).InsertOne (ctx , bson.D {{"_id" , 2 }})
16221622 suite .Require ().NoError (err )
1623+ suite .Require ().NoError (runner .StartNextGeneration ())
16231624 suite .Require ().NoError (runner .AwaitGenerationEnd ())
16241625 suite .waitForRecheckDocs (verifier )
16251626
0 commit comments