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 348d004 commit fa22407Copy full SHA for fa22407
internal/verifier/change_stream_test.go
@@ -156,6 +156,8 @@ func (suite *IntegrationTestSuite) TestChangeStreamFilter_WithNamespaces() {
156
157
changeStreamStopTime := sess.OperationTime()
158
159
+ suite.T().Logf("Insert op time: %v", changeStreamStopTime)
160
+
161
events := []bson.M{}
162
163
for {
@@ -164,6 +166,7 @@ func (suite *IntegrationTestSuite) TestChangeStreamFilter_WithNamespaces() {
164
166
csOpTime, err := extractTimestampFromResumeToken(cs.ResumeToken())
165
167
suite.Require().NoError(err, "should get timestamp from resume token")
168
169
+ suite.T().Logf("Change stream op time (got event? %v): %v", gotEvent, csOpTime)
170
if csOpTime.After(*changeStreamStopTime) {
171
break
172
}
0 commit comments