class SidekiqUniqueJobs::BatchDelete

def batch_delete(conn)

Returns:
  • (Integer) - the number of deleted digests
def batch_delete(conn)
  digests.each_slice(BATCH_SIZE) do |chunk|
    conn.pipelined do
      chunk.each do |digest|
        del_digest(conn, digest)
        conn.zrem(SidekiqUniqueJobs::DIGESTS, digest)
        @count += 1
      end
    end
  end
  @count
end