diff --git a/lib/sidekiq-rate-limiter/fetch.rb b/lib/sidekiq-rate-limiter/fetch.rb index 64342a0..3cb7a2b 100644 --- a/lib/sidekiq-rate-limiter/fetch.rb +++ b/lib/sidekiq-rate-limiter/fetch.rb @@ -32,7 +32,7 @@ def limit(work) } Sidekiq.redis do |conn| - s = Redis::Semaphore.new(:sidekiq_rate_limit_exceeded_check, redis: conn) + s = Redis::Semaphore.new(:sidekiq_rate_limit_exceeded_check, redis: Sidekiq::RedisConnection.create, stale_client_timeout: 60) lim = Limit.new(conn, options) limit_exceeded = nil