Fix: use redis client (#807)

frain-dev · Jun 28, 2022 · c70ab04 · c70ab04
1 parent 6b9490c
commit c70ab04
Showing 1 changed file with 1 addition and 5 deletions.
diff --git a/worker/scheduler.go b/worker/scheduler.go
@@ -16,11 +16,7 @@ type Scheduler struct {
 }
 
 func NewScheduler(queue queue.Queuer) *Scheduler {
-	scheduler := asynq.NewScheduler(asynq.RedisClientOpt{
-		Addr:     queue.Options().RedisAddress,
-		Password: "",
-		DB:       0,
-	}, nil)
+	scheduler := asynq.NewScheduler(queue.Options().RedisClient, nil)
 
 	w, err := NewConsumer(queue)
 	if err != nil {