From cab415cf61fb2c3dac4be42059ddebf94035d217 Mon Sep 17 00:00:00 2001 From: Matthias Hanel Date: Wed, 10 Mar 2021 11:49:18 -0500 Subject: [PATCH] Increasing test timeout Signed-off-by: Matthias Hanel --- server/jetstream_cluster_test.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/server/jetstream_cluster_test.go b/server/jetstream_cluster_test.go index ac15df65..3825c47e 100644 --- a/server/jetstream_cluster_test.go +++ b/server/jetstream_cluster_test.go @@ -5015,7 +5015,7 @@ func (c *cluster) consumerLeader(account, stream, consumer string) *Server { func (c *cluster) waitOnStreamLeader(account, stream string) { c.t.Helper() - expires := time.Now().Add(10 * time.Second) + expires := time.Now().Add(30 * time.Second) for time.Now().Before(expires) { if leader := c.streamLeader(account, stream); leader != nil { time.Sleep(100 * time.Millisecond)