diff --git a/inspector.go b/inspector.go
index d636b34..2c8498c 100644
--- a/inspector.go
+++ b/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
 }
 
diff --git a/scheduler.go b/scheduler.go
index dcb0aa0..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)
 	}
 }