From ced28eca9322eb3eb3b3a7b3b143c911ffa3922a Mon Sep 17 00:00:00 2001 From: Derek Collison Date: Sun, 13 Dec 2020 10:29:34 -0800 Subject: [PATCH] Fix flapper Signed-off-by: Derek Collison --- test/jetstream_test.go | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/test/jetstream_test.go b/test/jetstream_test.go index 806b5269..548738d2 100644 --- a/test/jetstream_test.go +++ b/test/jetstream_test.go @@ -1679,9 +1679,12 @@ func TestJetStreamWorkQueueWrapWaiting(t *testing.T) { } expectWaiting(0) - if nmsgs, _, _ := sub.Pending(); err != nil || nmsgs != maxWaiting+2 { - t.Fatalf("Expected sub to have %d pending, got %d", maxWaiting+2, nmsgs) - } + checkFor(t, 200*time.Millisecond, 10*time.Millisecond, func() error { + if nmsgs, _, _ := sub.Pending(); err != nil || nmsgs != maxWaiting+2 { + return fmt.Errorf("Expected sub to have %d pending, got %d", maxWaiting+2, nmsgs) + } + return nil + }) }) } }