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 84b6df6 commit 3c6383bCopy full SHA for 3c6383b
internal/verifier/change_stream_test.go
@@ -2,6 +2,7 @@ package verifier
2
3
import (
4
"context"
5
+ "fmt"
6
"testing"
7
"time"
8
@@ -218,8 +219,7 @@ func (suite *MultiSourceVersionTestSuite) TestWithChangeEventsBatching() {
218
219
require.Eventually(
220
suite.T(),
221
func() bool {
- // There should be 2 recheck docs due to batching, one for each namespace.
222
- return len(suite.fetchVerifierRechecks(ctx, verifier)) == 2
+ return len(suite.fetchVerifierRechecks(ctx, verifier)) == 3
223
},
224
time.Minute,
225
500*time.Millisecond,
0 commit comments