Skip to content

Commit 366acdd

Browse files
committed
deflake TestCacheLaggingWatcher by waiting for resync
Signed-off-by: Peter Chang <[email protected]>
1 parent a8822f3 commit 366acdd

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

tests/integration/cache_test.go

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1113,6 +1113,11 @@ func TestCacheLaggingWatcher(t *testing.T) {
11131113
ch := c.Watch(t.Context(), prefix, clientv3.WithPrefix())
11141114

11151115
generateEvents(t, client, prefix, tt.eventCount)
1116+
1117+
if tt.name == "pipeline overflow" {
1118+
time.Sleep(100 * time.Millisecond)
1119+
}
1120+
11161121
gotEvents, ok := collectAndAssertAtomicEvents(t, ch)
11171122
closed := !ok
11181123

0 commit comments

Comments
 (0)