diff --git a/periodic_task_manager.go b/periodic_task_manager.go index 3b927dd..c0fd01e 100644 --- a/periodic_task_manager.go +++ b/periodic_task_manager.go @@ -172,8 +172,8 @@ func (mgr *PeriodicTaskManager) add(configs []*PeriodicTaskConfig) { for _, c := range configs { entryID, err := mgr.s.Register(c.Cronspec, c.Task, c.Opts...) if err != nil { - mgr.s.logger.Errorf("Failed to register periodic task: cronspec=%q task=%q", - c.Cronspec, c.Task.Type()) + mgr.s.logger.Errorf("Failed to register periodic task: cronspec=%q task=%q err=%v", + c.Cronspec, c.Task.Type(), err) continue } mgr.m[c.hash()] = entryID diff --git a/scheduler.go b/scheduler.go index ecb3c3c..0026185 100644 --- a/scheduler.go +++ b/scheduler.go @@ -334,7 +334,6 @@ func (s *Scheduler) beat() { } entries = append(entries, e) } - s.logger.Debugf("Writing entries %v", entries) if err := s.rdb.WriteSchedulerEntries(s.id, entries, s.heartbeatInterval*2); err != nil { s.logger.Warnf("Scheduler could not write heartbeat data: %v", err) }