fix to handle when next ends up in the past

go-co-op · Dec 31, 2023 · 7700a27 · 7700a27
1 parent 73391ef
commit 7700a27
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/scheduler.go b/scheduler.go
@@ -290,6 +290,11 @@ func (s *scheduler) selectExecJobIDsOut(id uuid.UUID) {
 	if next.IsZero() {
 		return
 	}
+	if next.Before(s.now()) {
+		for next.Before(s.now()) {
+			next = j.next(next)
+		}
+	}
 	j.nextRun = next
 	j.timer = s.clock.AfterFunc(next.Sub(s.now()), func() {
 		select {