class SidekiqUniqueJobs::BatchDelete
def initialize(digests, conn)
-
conn
(Redis
) -- the connection to use for deletion -
digests
(Array
) -- the digests to delete
def initialize(digests, conn) @count = 0 @digests = digests @conn = conn @digests ||= [] @digests.compact! redis_version # Avoid pipelined calling redis_version and getting a future. end