Skip to content

Commit cf4bab6

Browse files
authored
scheduler: Check if next was missed (#85)
1 parent 11f0d0f commit cf4bab6

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

scheduler/scheduler.go

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -37,8 +37,8 @@ func NewScheduler() *Scheduler {
3737
return &Scheduler{notify: make(chan time.Time, 1), tc: make(chan time.Time, 1)}
3838
}
3939

40-
func (sched *Scheduler) WithDebug(debug *slog.Logger) *Scheduler {
41-
sched.debugLogger = debug
40+
func (sched *Scheduler) WithDebug(logger *slog.Logger) *Scheduler {
41+
sched.debugLogger = logger
4242
return sched
4343
}
4444

@@ -138,6 +138,9 @@ func (sched *Scheduler) checkMatched(t time.Time) {
138138
return
139139
}
140140
sched.debug("Scheduler Next Run Time", "Name", sched.sched, "Next", sched.next)
141+
} else if sched.next.Before(t) {
142+
sched.debug("Scheduler Missed Next", "Name", sched.sched, "Next", sched.next)
143+
sched.notify <- time.Now()
141144
}
142145
}
143146

0 commit comments

Comments
 (0)