Defer cancel on timeout for heartbeat

Signed-off-by: Anna Tran <[email protected]>
cortexproject · Sep 17, 2024 · d4d2612 · d4d2612
1 parent 3041b3c
commit d4d2612
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/pkg/ring/lifecycler.go b/pkg/ring/lifecycler.go
@@ -543,7 +543,8 @@ func (i *Lifecycler) loop(ctx context.Context) error {
 
 func (i *Lifecycler) heartbeat(ctx context.Context) {
 	i.lifecyclerMetrics.consulHeartbeats.Inc()
-	ctx, _ = context.WithTimeout(ctx, i.cfg.HeartbeatPeriod)
+	ctx, cancel := context.WithTimeout(ctx, i.cfg.HeartbeatPeriod)
+	defer cancel()
 	if err := i.updateConsul(context.Background()); err != nil {
 		level.Error(i.logger).Log("msg", "failed to write to the KV store, sleeping", "ring", i.RingName, "err", err)
 	}