Skip to content

Commit 9e85e8d

Browse files
committed
fix test
1 parent d951623 commit 9e85e8d

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
@@ -242,10 +242,10 @@ func (suite *IntegrationTestSuite) TestWithChangeEventsBatching() {
242242

243243
_, err := coll1.InsertOne(ctx, bson.D{{"_id", 1}})
244244
suite.Require().NoError(err)
245-
_, err = suite.srcMongoClient.Database("testDb").Collection("testColl1").InsertOne(ctx, bson.D{{"_id", 2}})
245+
_, err = coll1.InsertOne(ctx, bson.D{{"_id", 2}})
246246
suite.Require().NoError(err)
247247

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

251251
var rechecks []bson.M

0 commit comments

Comments
 (0)