diff --git a/scheduler.go b/scheduler.go index 0026185e..ba3152de 100644 --- a/scheduler.go +++ b/scheduler.go @@ -60,6 +60,7 @@ func NewScheduler(r RedisConnOpt, opts *SchedulerOpts) *Scheduler { } scheduler := NewSchedulerFromRedisClient(redisClient, opts) scheduler.sharedConnection = false + scheduler.client.sharedConnection = false return scheduler }