In Sidekiq 8:
work_set = Sidekiq::WorkSet.new work_set.any? do |process_id, thread_id, work| work.queue == 'imports_fetch_all' end