From 56462d5fea3b9ba58389ba4022d8d6388c394106 Mon Sep 17 00:00:00 2001 From: lamhieo02 Date: Tue, 2 Jul 2024 09:18:58 +0700 Subject: [PATCH] Fix for issue 510 --- scheduler.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/scheduler.go b/scheduler.go index 2655a946..0ea7d15d 100644 --- a/scheduler.go +++ b/scheduler.go @@ -10,11 +10,11 @@ import ( "sync" "time" - "github.com/redis/go-redis/v9" "github.com/google/uuid" "github.com/hibiken/asynq/internal/base" "github.com/hibiken/asynq/internal/log" "github.com/hibiken/asynq/internal/rdb" + "github.com/redis/go-redis/v9" "github.com/robfig/cron/v3" ) @@ -268,7 +268,7 @@ func (s *Scheduler) Shutdown() { func (s *Scheduler) runHeartbeater() { defer s.wg.Done() - ticker := time.NewTicker(5 * time.Second) + ticker := time.NewTicker(10 * time.Second) for { select { case <-s.done: @@ -299,7 +299,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, 10*time.Second); err != nil { s.logger.Warnf("Scheduler could not write heartbeat data: %v", err) } }