fix: in progress ticker should also mark jetstream message as in prog…

…ress
verifa · Mar 14, 2024 · 092ab47 · 092ab47
1 parent 79f821f
commit 092ab47
Showing 1 changed file with 5 additions and 2 deletions.
diff --git 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
 			}