From a67947178d36bea0cd29a87dc55fd26689fcbd87 Mon Sep 17 00:00:00 2001 From: Lev Zakharov Date: Fri, 5 Apr 2024 18:20:56 +0300 Subject: [PATCH] watchdog: fix processed job handling --- watchdog.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/watchdog.go b/watchdog.go index d91c0a56..16fa4642 100644 --- a/watchdog.go +++ b/watchdog.go @@ -155,7 +155,7 @@ func (w *watchdog) processed(j *Job) { job.each(func(h *checkTimesHeap) bool { n, _ := h.Peek() - if n.Before(time.Unix(j.EnqueuedAt, 0)) { + if !n.After(time.Unix(j.EnqueuedAt, 0)) { h.Pop() job.processed.Add(1)