class SidekiqUniqueJobs::BatchDelete

def initialize(digests, conn)

Parameters:
  • 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