lib/sidekiq_unique_jobs/connection.rb in sidekiq-unique-jobs-7.1.33 vs lib/sidekiq_unique_jobs/connection.rb in sidekiq-unique-jobs-8.0.0
- old
+ new
@@ -8,16 +8,13 @@
def self.included(base)
base.send(:extend, self)
end
# Creates a connection to redis
- # @return [Sidekiq::RedisConnection, ConnectionPool] a connection to redis
- def redis(r_pool = nil, &block)
- r_pool ||= defined?(redis_pool) ? redis_pool : r_pool
- if r_pool
- r_pool.with(&block)
- else
- Sidekiq.redis(&block)
+ # @return [Sidekiq::RedisConnection] a connection to redis
+ def redis(_r_pool = nil, &block)
+ Sidekiq.redis do |conn|
+ conn.with(&block)
end
end
end
end