diff --git a/app/models/event.rb b/app/models/event.rb index 0b06527..984029f 100644 --- a/app/models/event.rb +++ b/app/models/event.rb @@ -156,10 +156,9 @@ def reindex_touched_dois(start_date:, end_date:, threads: 10) .distinct.pluck(:target_doi) .each { |doi| dois << doi } - # Test performance before enabling SQS queues. - # Parallel.each(dois.to_a, in_threads: threads) do |doi| - # SqsUtilities.send_events_doi_index_message(doi) - # end + Parallel.each(dois, in_threads: threads) do |doi| + SqsUtilities.send_events_doi_index_message({ doi: doi }) + end total += dois.size end