diff --git a/internal/verifier/change_stream_test.go b/internal/verifier/change_stream_test.go index 7feaf40..f33977a 100644 --- 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,