diff --git a/asynq.go b/asynq.go
index e2bfeec..ef4253d 100644
--- a/asynq.go
+++ b/asynq.go
@@ -177,21 +177,23 @@ func createRedisClient(r RedisConnOpt) *redis.Client {
 	switch r := r.(type) {
 	case *RedisClientOpt:
 		return redis.NewClient(&redis.Options{
-			Network:   r.Network,
-			Addr:      r.Addr,
-			Password:  r.Password,
-			DB:        r.DB,
-			PoolSize:  r.PoolSize,
-			TLSConfig: r.TLSConfig,
+			Network:    r.Network,
+			Addr:       r.Addr,
+			Password:   r.Password,
+			DB:         r.DB,
+			PoolSize:   r.PoolSize,
+			TLSConfig:  r.TLSConfig,
+			MaxRetries: 10,
 		})
 	case RedisClientOpt:
 		return redis.NewClient(&redis.Options{
-			Network:   r.Network,
-			Addr:      r.Addr,
-			Password:  r.Password,
-			DB:        r.DB,
-			PoolSize:  r.PoolSize,
-			TLSConfig: r.TLSConfig,
+			Network:    r.Network,
+			Addr:       r.Addr,
+			Password:   r.Password,
+			DB:         r.DB,
+			PoolSize:   r.PoolSize,
+			TLSConfig:  r.TLSConfig,
+			MaxRetries: 10,
 		})
 	case *RedisFailoverClientOpt:
 		return redis.NewFailoverClient(&redis.FailoverOptions{
diff --git a/heartbeat.go b/heartbeat.go
index cc59a76..3bb81f3 100644
--- a/heartbeat.go
+++ b/heartbeat.go
@@ -165,14 +165,23 @@ func (h *heartbeater) beat() {
 	}
 
 	// Debug purpose
-	rdb, ok := h.broker.(*rdb.RDB)
+	r, ok := h.broker.(*rdb.RDB)
 	if !ok {
 		return
 	}
-	stats, err := rdb.CurrentStats()
+	stats, err := r.CurrentStats()
 	if err != nil {
 		h.logger.Errorf("could not get current stat: %v", err)
 	} else {
 		h.logger.Debugf("current stats: %+v", stats)
 	}
+
+	inProgress, err := r.ListInProgress(rdb.Pagination{Size: 10})
+	if err != nil {
+		h.logger.Errorf("could not get in-progress tasks: %v", err)
+	} else {
+		for _, t := range inProgress {
+			h.logger.Debugf("in-progress tasks: %+v", t)
+		}
+	}
 }
diff --git a/syncer.go b/syncer.go
index c5ca396..ee09949 100644
--- a/syncer.go
+++ b/syncer.go
@@ -71,8 +71,10 @@ func (s *syncer) start(wg *sync.WaitGroup) {
 				requests = append(requests, req)
 			case <-time.After(s.interval):
 				var temp []*syncRequest
+				s.logger.Infof("sync requests length: %d", len(requests))
 				for _, req := range requests {
 					if err := req.fn(); err != nil {
+						s.logger.Errorf("could not sync: %v: %v", req.errMsg, err)
 						temp = append(temp, req)
 					}
 				}