module SidekiqBulk
Public Instance Methods
push_bulk(items, limit: 10_000, &block)
click to toggle source
# File lib/sidekiq/bulk.rb, line 4 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
push_bulk!(items, &block)
click to toggle source
# File lib/sidekiq/bulk.rb, line 12 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