From f94568d761aa9bc4a459dd4242dea533a60d6a31 Mon Sep 17 00:00:00 2001 From: Andrew Kane Date: Tue, 30 Jul 2019 20:21:09 -0700 Subject: [PATCH] Cleaner code [skip ci] --- lib/searchkick/process_queue_job.rb | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/lib/searchkick/process_queue_job.rb b/lib/searchkick/process_queue_job.rb index f5596a5..c300883 100644 --- a/lib/searchkick/process_queue_job.rb +++ b/lib/searchkick/process_queue_job.rb @@ -4,13 +4,13 @@ module Searchkick def perform(class_name:) model = class_name.constantize - limit = model.searchkick_index.options[:batch_size] || 1000 + limit = model.searchkick_options[:batch_size] || 1000 loop do record_ids = model.searchkick_index.reindex_queue.reserve(limit: limit) if record_ids.any? Searchkick::ProcessBatchJob.perform_later( - class_name: model.name, + class_name: class_name, record_ids: record_ids ) # TODO when moving to reliable queuing, mark as complete -- libgit2 0.21.0