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 }