From 8dbfbbe577a368ad91ef81a2ca7a72deb8884a69 Mon Sep 17 00:00:00 2001 From: Derek Collison Date: Wed, 15 Mar 2023 17:23:51 -0700 Subject: [PATCH] Fix test Signed-off-by: Derek Collison --- server/jetstream_cluster_3_test.go | 1 + 1 file changed, 1 insertion(+) diff --git a/server/jetstream_cluster_3_test.go b/server/jetstream_cluster_3_test.go index 05c1a45e..dab9e3e0 100644 --- a/server/jetstream_cluster_3_test.go +++ b/server/jetstream_cluster_3_test.go @@ -2958,6 +2958,7 @@ func TestJetStreamClusterWorkQueueConsumerReplicatedAfterScaleUp(t *testing.T) { require_True(t, ci.Config.Replicas == 0 || ci.Config.Replicas == 3) + c.waitOnConsumerLeader(globalAccountName, "TEST", ci.Name) s := c.consumerLeader(globalAccountName, "TEST", ci.Name) require_NotNil(t, s)