Skip to content

Commit 4ae766e

Browse files
Merge pull request #83 from datacite/doi-reindex-fix
Permit SQS messages and correct message body format
2 parents c1529c3 + 7de48a6 commit 4ae766e

1 file changed

Lines changed: 3 additions & 4 deletions

File tree

app/models/event.rb

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -156,10 +156,9 @@ def reindex_touched_dois(start_date:, end_date:, threads: 10)
156156
.distinct.pluck(:target_doi)
157157
.each { |doi| dois << doi }
158158

159-
# Test performance before enabling SQS queues.
160-
# Parallel.each(dois.to_a, in_threads: threads) do |doi|
161-
# SqsUtilities.send_events_doi_index_message(doi)
162-
# end
159+
Parallel.each(dois, in_threads: threads) do |doi|
160+
SqsUtilities.send_events_doi_index_message({ doi: doi })
161+
end
163162

164163
total += dois.size
165164
end

0 commit comments

Comments
 (0)