diff options
Diffstat (limited to 'jobs/schedulers.go')
| -rw-r--r-- | jobs/schedulers.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/jobs/schedulers.go b/jobs/schedulers.go index 3d52c969a..cbe5f1749 100644 --- a/jobs/schedulers.go +++ b/jobs/schedulers.go @@ -65,10 +65,10 @@ func (schedulers *Schedulers) Start() *Schedulers { now := time.Now() for idx, scheduler := range schedulers.schedulers { - if !scheduler.Enabled(utils.Cfg) { + if !scheduler.Enabled(schedulers.jobs.Config()) { schedulers.nextRunTimes[idx] = nil } else { - schedulers.setNextRunTime(utils.Cfg, idx, now, false) + schedulers.setNextRunTime(schedulers.jobs.Config(), idx, now, false) } } @@ -78,7 +78,7 @@ func (schedulers *Schedulers) Start() *Schedulers { l4g.Debug("Schedulers received stop signal.") return case now = <-time.After(1 * time.Minute): - cfg := utils.Cfg + cfg := schedulers.jobs.Config() for idx, nextTime := range schedulers.nextRunTimes { if nextTime == nil { |