class SidekiqUniqueJobs::Orphans::RubyReaper
def active?(digest)
def active?(digest) Sidekiq.redis do |conn| procs = conn.sscan_each("processes").to_a.sort result = conn.pipelined do procs.map do |key| conn.hget(key, "info") end end result.flatten.compact.any? { |job| load_json(job)[LOCK_DIGEST] == digest } end end