lib/searchkick/reindex_queue.rb in searchkick-4.5.1 vs lib/searchkick/reindex_queue.rb in searchkick-4.5.2
- old
+ new
@@ -13,10 +13,10 @@
end
# TODO use reliable queuing
def reserve(limit: 1000)
if supports_rpop_with_count?
- Searchkick.with_redis { |r| r.call("rpop", redis_key, limit) }
+ Searchkick.with_redis { |r| r.call("rpop", redis_key, limit) }.to_a
else
record_ids = []
Searchkick.with_redis do |r|
while record_ids.size < limit && (record_id = r.rpop(redis_key))
record_ids << record_id