diff --git a/pkg/hz/controller.go b/pkg/hz/controller.go index 75f8031..e5492bb 100644 --- a/pkg/hz/controller.go +++ b/pkg/hz/controller.go @@ -507,10 +507,13 @@ func (c *Controller) handleControlLoop( case <-ctx.Done(): return case <-ticker.C: + slog.Info("ticker in progress") if err := lock.InProgress(); err != nil { - slog.Error("marking message in progress", "error", err) + slog.Error("resetting mutex lock", "error", err) + } + if err := msg.InProgress(); err != nil { + slog.Error("marking message in progress", "error", err) } - slog.Info("ticker in progress") case <-reconcileDone: return }