diff --git a/internal/scheduler/scheduler.go b/internal/scheduler/scheduler.go index a168489..32deccd 100644 --- a/internal/scheduler/scheduler.go +++ b/internal/scheduler/scheduler.go @@ -374,7 +374,7 @@ func (c *SchedulerCycle) run() { } // workers launches `MaxWorkers` number of worker to execute job. -// If job returns `ErrJobNotCompletedYet`, it re-schedules in the same slot. +// If job returns `ErrJobNotCompletedYet`, it re-schedules in the current slot. func (c *SchedulerCycle) workers() { for i := 0; i < MaxWorkers; i++ { c.wg.Add(1)