Mercurial > gemma

comparison pkg/scheduler/scheduler.go @ 2955:e9ff3e8d3c46

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Import scheduler: Log number of scheduler jobs to start from database during boot time.
author Sascha L. Teichmann <sascha.teichmann@intevation.de>
date Mon, 08 Apr 2019 11:58:00 +0200
parents 6691bf76af1c
children 64324aaeb1fb
comparison
equal deleted inserted replaced
2954:972400e56e4a 2955:e9ff3e8d3c46
76 76
77 func (s *scheduler) bootActions(next func(*BoundAction) (bool, error)) error { 77 func (s *scheduler) bootActions(next func(*BoundAction) (bool, error)) error {
78 78
79 cr := cron.New() 79 cr := cron.New()
80 80
81 var numJobs int
82
81 for { 83 for {
82 var ba BoundAction 84 var ba BoundAction
83 ok, err := next(&ba) 85 ok, err := next(&ba)
84 if err != nil { 86 if err != nil {
85 return err 87 return err
95 scheduler: s, 97 scheduler: s,
96 name: ba.Name, 98 name: ba.Name,
97 cfgID: ba.CfgID, 99 cfgID: ba.CfgID,
98 } 100 }
99 cr.Schedule(schedule, job) 101 cr.Schedule(schedule, job)
100 } 102 numJobs++
103 }
104
105 log.Printf("info: booting %d scheduler jobs from database.\n", numJobs)
101 106
102 s.mu.Lock() 107 s.mu.Lock()
103 defer s.mu.Unlock() 108 defer s.mu.Unlock()
104 109
105 s.cr.Stop() 110 s.cr.Stop()