We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 8140003 commit a4086dfCopy full SHA for a4086df
internal/verifier/change_stream_test.go
@@ -162,7 +162,13 @@ func (suite *IntegrationTestSuite) TestStartAtTimeWithChanges() {
162
suite.Require().NotNil(origSessionTime)
163
err = verifier.StartChangeStream(ctx)
164
suite.Require().NoError(err)
165
- suite.Require().Equal(verifier.srcStartAtTs, origSessionTime)
+
166
+ // srcStartAtTs derives from the change stream’s resume token, which can
167
+ // postdate our session time but should not precede it.
168
+ suite.Require().False(
169
+ verifier.srcStartAtTs.Before(*origSessionTime),
170
+ "srcStartAtTs should be >= the insert’s optime",
171
+ )
172
173
_, err = suite.srcMongoClient.Database("testDb").Collection("testColl").InsertOne(
174
sctx, bson.D{{"_id", 1}})
0 commit comments