From 70af04a63f02803ee50d2b1b8aab00359fa6d9b1 Mon Sep 17 00:00:00 2001 From: Ivan Kozlovic Date: Fri, 28 Apr 2023 11:02:19 -0600 Subject: [PATCH] Other flappers. Signed-off-by: Ivan Kozlovic --- server/norace_test.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/server/norace_test.go b/server/norace_test.go index 3cb44650..14ff1acc 100644 --- a/server/norace_test.go +++ b/server/norace_test.go @@ -1691,6 +1691,7 @@ func TestNoRaceJetStreamSuperClusterMixedModeMirrors(t *testing.T) { if _, err := js.AddStream(&nats.StreamConfig{Name: name}); err != nil { t.Fatalf("Unexpected error: %v", err) } + c.waitOnStreamLeader(globalAccountName, name) // Load them up with a bunch of messages. for n := 0; n < toSend; n++ { m := nats.NewMsg(name) @@ -2000,6 +2001,7 @@ func TestNoRaceJetStreamSuperClusterMixedModeSources(t *testing.T) { if _, err := js.AddStream(&nats.StreamConfig{Name: name}); err != nil { t.Fatalf("Unexpected error: %v", err) } + c.waitOnStreamLeader(globalAccountName, name) // Load them up with a bunch of messages. for n := 0; n < toSend; n++ { m := nats.NewMsg(name)