class SidekiqUniqueJobs::BatchDelete
def batch_delete(conn)
-
(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