diff --git a/job/cache.go b/job/cache.go index 1e9bec5..6484b21 100644 --- a/job/cache.go +++ b/job/cache.go @@ -88,7 +88,10 @@ func (c *MemoryJobCache) Start(persistWaitTime time.Duration) { log.Infof("Shutting down....") // Persist all jobs to database - log.Errorln(c.Persist()) + err = c.Persist() + if err != nil { + log.Errorln(err) + } // Close the database c.jobDB.Close()