aprescott/sidekiq-bulk

require "sidekiq"

module SidekiqBulk
  def push_bulk(items, limit: 10_000, &block)
    job_ids = items.each_slice(limit).map do |group|
      push_bulk!(group, &block)
    end

    job_ids.flatten
  end

  def push_bulk!(items, &block)
    if block
      args = items.map(&block)
    else
      args = items.map { |el| [el] }
    end

    Sidekiq::Client.push_bulk("class" => self, "args" => args)
  end
end

Sidekiq::Worker::ClassMethods.module_eval { include SidekiqBulk }