mirror of
https://github.com/hibiken/asynq.git
synced 2025-04-20 15:50:20 +08:00
mark the client that the scheduler made also as non-shared
This commit is contained in:
parent
106c07adaa
commit
5dfa74254f
@ -60,6 +60,7 @@ func NewScheduler(r RedisConnOpt, opts *SchedulerOpts) *Scheduler {
|
|||||||
}
|
}
|
||||||
scheduler := NewSchedulerFromRedisClient(redisClient, opts)
|
scheduler := NewSchedulerFromRedisClient(redisClient, opts)
|
||||||
scheduler.sharedConnection = false
|
scheduler.sharedConnection = false
|
||||||
|
scheduler.client.sharedConnection = false
|
||||||
return scheduler
|
return scheduler
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user