class SidekiqUniqueJobs::UpgradeLocks

def upgrade_v6_lock(grabbed_key)
  locked_key = grabbed_key.gsub(":GRABBED", ":LOCKED")
  digest     = grabbed_key.gsub(":GRABBED", "")
  locks      = conn.hgetall(grabbed_key)
  conn.pipelined do
    conn.hmset(locked_key, *locks.to_a)
    conn.zadd(DIGESTS, locks.values.first, digest)
  end
end