Better inline

Andrew Kane
1 parent b294478d
Showing 1 changed file with 9 additions and 4 deletions Show diff stats
lib/searchkick/process_queue_job.rb
@@ -9,13 +9,18 @@ module Searchkick
       loop do
         record_ids = model.searchkick_index(name: index_name).reindex_queue.reserve(limit: limit)
         if record_ids.any?
-          perform_method = inline ? :perform_now : :perform_later
-          Searchkick::ProcessBatchJob.send(
-            perform_method,
+          batch_options = {
             class_name: class_name,
             record_ids: record_ids,
             index_name: index_name
-          )
+          }
+
+          if inline
+            Searchkick::ProcessBatchJob.new.perform(**batch_options)
+          else
+            Searchkick::ProcessBatchJob.perform_later(**batch_options)
+          end
+
           # TODO when moving to reliable queuing, mark as complete
         end
         break unless record_ids.size == limit
...	...	@@ -9,13 +9,18 @@ module Searchkick
9	9	loop do
10	10	record_ids = model.searchkick_index(name: index_name).reindex_queue.reserve(limit: limit)
11	11	if record_ids.any?
12		- perform_method = inline ? :perform_now : :perform_later
13		- Searchkick::ProcessBatchJob.send(
14		- perform_method,
	12	+ batch_options = {
15	13	class_name: class_name,
16	14	record_ids: record_ids,
17	15	index_name: index_name
18		- )
	16	+ }
	17	+
	18	+ if inline
	19	+ Searchkick::ProcessBatchJob.new.perform(**batch_options)
	20	+ else
	21	+ Searchkick::ProcessBatchJob.perform_later(**batch_options)
	22	+ end
	23	+
19	24	# TODO when moving to reliable queuing, mark as complete
20	25	end
21	26	break unless record_ids.size == limit
...	...