comment

FGasper · FGasper · commit 07effe5a2e3d · 2024-12-11T09:50:21.000-05:00
diff --git a/internal/verifier/change_stream_test.go b/internal/verifier/change_stream_test.go
@@ -345,6 +345,8 @@ func (suite *IntegrationTestSuite) TestChangeStreamLag() {
 		100*time.Millisecond,
 	)
 
+	// NB: The lag will include whatever time elapsed above before
+	// verifier read the event, so it can be several seconds.
 	suite.Assert().Less(
 		verifier.srcChangeStreamReader.GetLag().MustGet(),
 		10*time.Minute,

Original file line number	Diff line number	Diff line change
`@@ -345,6 +345,8 @@ func (suite *IntegrationTestSuite) TestChangeStreamLag() {`
`345`	`345`	`100*time.Millisecond,`
`346`	`346`	`)`
`347`	`347`
	`348`	`+ // NB: The lag will include whatever time elapsed above before`
	`349`	`+ // verifier read the event, so it can be several seconds.`
`348`	`350`	`suite.Assert().Less(`
`349`	`351`	`verifier.srcChangeStreamReader.GetLag().MustGet(),`
`350`	`352`	`10*time.Minute,`