From db00144cabd7f4462007313b559b5c77d24ad0d2 Mon Sep 17 00:00:00 2001 From: Ingo Oppermann Date: Thu, 22 Jun 2023 15:12:44 +0200 Subject: [PATCH] Clear locks only if not in emergency mode --- cluster/leader.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/cluster/leader.go b/cluster/leader.go index e53a873c..63cc1fbd 100644 --- a/cluster/leader.go +++ b/cluster/leader.go @@ -293,7 +293,10 @@ func (c *cluster) establishLeadership(ctx context.Context, emergency bool) error c.cancelLeaderShip = cancel go c.synchronizeAndRebalance(ctx, c.syncInterval, emergency) - go c.clearLocks(ctx, time.Minute) + + if !emergency { + go c.clearLocks(ctx, time.Minute) + } return nil }