From 85cc5c78703f7548fa0fa907c5a6c5a438744b90 Mon Sep 17 00:00:00 2001 From: Barkhayot Juraev Date: Wed, 28 Jan 2026 19:31:32 +0900 Subject: [PATCH] fix: update next job scheduling --- scheduler.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/scheduler.go b/scheduler.go index 7efeb97..b0538b3 100644 --- a/scheduler.go +++ b/scheduler.go @@ -443,11 +443,11 @@ func (s *scheduler) updateNextScheduled(id uuid.UUID) { return } var newNextScheduled []time.Time + now := s.now() for _, t := range j.nextScheduled { - if t.Before(s.now()) { - continue + if t.After(now) { // Changed to match selectExecJobsOutCompleted + newNextScheduled = append(newNextScheduled, t) } - newNextScheduled = append(newNextScheduled, t) } j.nextScheduled = newNextScheduled s.jobs[id] = j