fix: update next job scheduling

This commit is contained in:
Barkhayot Juraev 2026-01-28 19:31:32 +09:00
parent c1f0075822
commit 85cc5c7870
1 changed files with 3 additions and 3 deletions

View File

@ -443,11 +443,11 @@ func (s *scheduler) updateNextScheduled(id uuid.UUID) {
return return
} }
var newNextScheduled []time.Time var newNextScheduled []time.Time
now := s.now()
for _, t := range j.nextScheduled { for _, t := range j.nextScheduled {
if t.Before(s.now()) { if t.After(now) { // Changed to match selectExecJobsOutCompleted
continue newNextScheduled = append(newNextScheduled, t)
} }
newNextScheduled = append(newNextScheduled, t)
} }
j.nextScheduled = newNextScheduled j.nextScheduled = newNextScheduled
s.jobs[id] = j s.jobs[id] = j