From ac6aa0e103587a23a8bd9bf03d35f5bf027d03cd Mon Sep 17 00:00:00 2001
From: codycooperross <50597551+codycooperross@users.noreply.github.com>
Date: Wed, 11 Mar 2026 16:38:14 -0400
Subject: [PATCH 1/2] Permit SQS messages and correct message body format

---
 app/models/event.rb | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git a/app/models/event.rb b/app/models/event.rb
index 0b06527..c36c74c 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.to_a, in_threads: threads) do |doi|
+          SqsUtilities.send_events_doi_index_message({ doi: doi })
+        end
 
         total += dois.size
       end

From 7de48a6ae4ad1d7f66f447d7049b0c4ffdf66c7e Mon Sep 17 00:00:00 2001
From: codycooperross <50597551+codycooperross@users.noreply.github.com>
Date: Thu, 12 Mar 2026 08:38:51 -0400
Subject: [PATCH 2/2] Remove to_a since set is enumerable

---
 app/models/event.rb | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/app/models/event.rb b/app/models/event.rb
index c36c74c..984029f 100644
--- a/app/models/event.rb
+++ b/app/models/event.rb
@@ -156,7 +156,7 @@ def reindex_touched_dois(start_date:, end_date:, threads: 10)
           .distinct.pluck(:target_doi)
           .each { |doi| dois << doi }
 
-        Parallel.each(dois.to_a, in_threads: threads) do |doi|
+        Parallel.each(dois, in_threads: threads) do |doi|
           SqsUtilities.send_events_doi_index_message({ doi: doi })
         end