# File lib/sidekiq/limit_fetch.rb, line 23 def retrieve_work queue, job = redis_brpop(Queues.acquire) Queues.release_except(queue) UnitOfWork.new(queue, job) if job end