Merge pull request #1 from easy-monitor/pacino/tasks

chore(): 任务ttl设置为60s

inspector.go

@@ -6,6 +6,7 @@ package asynq
 
 import (
 	"fmt"
+
 	"strconv"
 	"strings"
 	"time"
@@ -799,6 +800,7 @@ func (i *Inspector) SchedulerEntries() ([]*SchedulerEntry, error) {
 	if err != nil {
 		return nil, err
 	}
+
 	for _, e := range res {
 		task := NewTask(e.Type, e.Payload)
 		var opts []Option
@@ -817,6 +819,7 @@ func (i *Inspector) SchedulerEntries() ([]*SchedulerEntry, error) {
 			Prev: e.Prev,
 		})
 	}
+
 	return entries, nil
 }
 

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