reindex_v2_job.rb
487 Bytes
module Searchkick
class ReindexV2Job < ActiveJob::Base
queue_as { Searchkick.queue_name }
def perform(klass, id, method_name = nil, routing: nil)
model = klass.constantize
# may not be needed if calling search_import later
model = model.unscoped if model.respond_to?(:unscoped)
items = [{id: id, routing: routing}]
model.searchkick_index.send(:record_indexer).reindex_items(model, items, method_name: method_name, single: true)
end
end
end