chore(): 调度者队列任务过期时间设置为60s

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
-}