diff --git a/scheduler.go b/scheduler.go index 9f74f9d..6a87e66 100644 --- a/scheduler.go +++ b/scheduler.go @@ -276,7 +276,7 @@ func (s *Scheduler) beat() { entries = append(entries, e) } s.logger.Debugf("Writing entries %v", entries) - if err := s.rdb.WriteSchedulerEntries(s.id, entries, 5*time.Second); err != nil { + if err := s.rdb.WriteSchedulerEntries(s.id, entries, 60*time.Second); err != nil { s.logger.Warnf("Scheduler could not write heartbeat data: %v", err) } } @@ -297,28 +297,3 @@ func (s *Scheduler) clearHistory() { } } } - -func (s *Scheduler) GetEntries() ([]*SchedulerEntry, error) { - var entries []*SchedulerEntry - - for _, entry := range s.cron.Entries() { - job := entry.Job.(*enqueueJob) - var opts []Option - opt := stringifyOptions(job.opts) - for _, s := range opt { - if o, err := parseOption(s); err == nil { - // ignore bad data - opts = append(opts, o) - } - } - entries = append(entries, &SchedulerEntry{ - ID: job.id.String(), - Spec: job.cronspec, - Task: job.task, - Opts: opts, - Next: entry.Next, - Prev: entry.Prev, - }) - } - return entries, nil -}