From 7b54a1e6a1f4e544af1159c328b75f907e4b7fa2 Mon Sep 17 00:00:00 2001 From: Tomasz Pietrek Date: Fri, 8 Sep 2023 11:34:16 +0200 Subject: [PATCH] Fix TestNoRaceJetStreamSparseConsumers This is the same fix as in https://github.com/nats-io/nats-server/pull/4500 This means it adds `StallWait` to `PublishAsync`, as that's seems to be the only reason why this test fails. Signed-off-by: Tomasz Pietrek --- server/norace_test.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/server/norace_test.go b/server/norace_test.go index 6742528f..9dbb6c1e 100644 --- a/server/norace_test.go +++ b/server/norace_test.go @@ -4321,14 +4321,14 @@ func TestNoRaceJetStreamSparseConsumers(t *testing.T) { // We will purposely place foo msgs near the beginning, then in middle, then at the end. for n := 0; n < 2; n++ { - _, err = js.PublishAsync("foo", msg) + _, err = js.PublishAsync("foo", msg, nats.StallWait(800*time.Millisecond)) require_NoError(t, err) for i := 0; i < 1_000_000; i++ { - _, err = js.PublishAsync("bar", msg) + _, err = js.PublishAsync("bar", msg, nats.StallWait(800*time.Millisecond)) require_NoError(t, err) } - _, err = js.PublishAsync("foo", msg) + _, err = js.PublishAsync("foo", msg, nats.StallWait(800*time.Millisecond)) require_NoError(t, err) } select {