From 6e20f6270b89755ef7f52d4effbf6174c88e7f50 Mon Sep 17 00:00:00 2001 From: Maurice van Veen Date: Fri, 4 Oct 2024 14:02:25 +0200 Subject: [PATCH] De-flake TestNoRaceJetStreamClusterGhostConsumers Signed-off-by: Maurice van Veen --- server/jetstream_cluster_3_test.go | 2 +- server/norace_test.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/server/jetstream_cluster_3_test.go b/server/jetstream_cluster_3_test.go index 001b114c9ee..266125ad3da 100644 --- a/server/jetstream_cluster_3_test.go +++ b/server/jetstream_cluster_3_test.go @@ -1600,7 +1600,7 @@ func TestJetStreamClusterParallelConsumerCreation(t *testing.T) { } func TestJetStreamClusterGhostEphemeralsAfterRestart(t *testing.T) { - consumerNotActiveStartInterval = time.Second * 5 + consumerNotActiveStartInterval = time.Second defer func() { consumerNotActiveStartInterval = defaultConsumerNotActiveStartInterval }() diff --git a/server/norace_test.go b/server/norace_test.go index 98d29cb2bc0..f0cc31f4b3c 100644 --- a/server/norace_test.go +++ b/server/norace_test.go @@ -6577,7 +6577,7 @@ func TestNoRaceJetStreamConsumerCreateTimeNumPending(t *testing.T) { } func TestNoRaceJetStreamClusterGhostConsumers(t *testing.T) { - consumerNotActiveStartInterval = time.Second * 5 + consumerNotActiveStartInterval = time.Second defer func() { consumerNotActiveStartInterval = defaultConsumerNotActiveStartInterval }()