Commit 15df2a555744926c1b786eb6fdec4698ac2b8030

Authored by Andrew
1 parent 17f9162b
Exists in routing_queue

Only add routing if exists [skip ci]

Showing 1 changed file with 2 additions and 1 deletions   Show diff stats
lib/searchkick/record_indexer.rb
... ... @@ -26,7 +26,8 @@ module Searchkick
26 26 routing = record.search_routing
27 27 end
28 28  
29   - value = [record.id.to_s, routing].join("|")
  29 + value = record.id.to_s
  30 + value = "#{value}|#{routing}" if routing
30 31 index.reindex_queue.push(value)
31 32 when :async
32 33 unless defined?(ActiveJob)
... ...