diff options
| author | Chris <ccbrown112@gmail.com> | 2017-11-09 14:46:20 -0600 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2017-11-09 14:46:20 -0600 |
| commit | 10c5a927cb619f1aa2a599cbe3667820f4766bda (patch) | |
| tree | f415540ab66115e62928d304c99b533398d7f226 /jobs | |
| parent | b0c18ece0988b1573b2286bb73b32e48a1d8c59a (diff) | |
| download | chat-10c5a927cb619f1aa2a599cbe3667820f4766bda.tar.gz chat-10c5a927cb619f1aa2a599cbe3667820f4766bda.tar.bz2 chat-10c5a927cb619f1aa2a599cbe3667820f4766bda.zip | |
more global config ref cleanup (#7802)
Diffstat (limited to 'jobs')
| -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 { |