Skip to content

Commit a3c6f73

Browse files
committed
fix test
1 parent ead2a35 commit a3c6f73

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

internal/verifier/change_stream_test.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -236,10 +236,10 @@ func (suite *IntegrationTestSuite) TestWithChangeEventsBatching() {
236236

237237
_, err := coll1.InsertOne(ctx, bson.D{{"_id", 1}})
238238
suite.Require().NoError(err)
239-
_, err = suite.srcMongoClient.Database("testDb").Collection("testColl1").InsertOne(ctx, bson.D{{"_id", 2}})
239+
_, err = coll1.InsertOne(ctx, bson.D{{"_id", 2}})
240240
suite.Require().NoError(err)
241241

242-
_, err = suite.srcMongoClient.Database("testDb").Collection("testColl2").InsertOne(ctx, bson.D{{"_id", 1}})
242+
_, err = coll2.InsertOne(ctx, bson.D{{"_id", 1}})
243243
suite.Require().NoError(err)
244244

245245
var rechecks []bson.M

0 commit comments

Comments
 (0)