diff --git a/plugin/cron/cron.go b/plugin/cron/cron.go index 03411ddb0..f9318ced5 100644 --- a/plugin/cron/cron.go +++ b/plugin/cron/cron.go @@ -306,11 +306,9 @@ func (c *Cron) runScheduler() { // startJob runs the given job in a new goroutine. func (c *Cron) startJob(j Job) { - c.jobWaiter.Add(1) - go func() { - defer c.jobWaiter.Done() + c.jobWaiter.Go(func() { j.Run() - }() + }) } // now returns current time in c location.