From 45aad439e05541ea9e8cc4a88a6e007eb4b8bdd6 Mon Sep 17 00:00:00 2001 From: Wendel Fabian Chinsamy Date: Wed, 12 Nov 2025 10:39:42 +0200 Subject: [PATCH 1/2] Increase the date range for the crossref other doi rake --- lib/tasks/event.rake | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/lib/tasks/event.rake b/lib/tasks/event.rake index 65aca0b..6ce2a38 100644 --- a/lib/tasks/event.rake +++ b/lib/tasks/event.rake @@ -1,12 +1,14 @@ # frozen_string_literal: true +require "active_support/all" + namespace :event do desc "Import Crossref DOIs for events created within a date range" # example command: IMPORT_DATE=2025-06-11 bundle exec rake event:import_crossref_event_dois task import_crossref_event_dois: :environment do date = Date.parse(ENV["IMPORT_DATE"]) start_date = date.beginning_of_day - end_date = (date + 1).beginning_of_day + end_date = (date + 1.month).beginning_of_month.beginning_of_day puts("Import date: #{date}") puts("Start date: #{start_date}") @@ -17,6 +19,7 @@ namespace :event do .where(created_at: start_date...end_date) puts("Number of events: #{events.count}") + puts("Enqueueing messages to events_other_doi_job...") Parallel.each(events, in_threads: 20) do |event| SqsUtilities.send_events_other_doi_job_message({ @@ -24,5 +27,7 @@ namespace :event do obj_id: event.obj_id, }) end + + puts("Task complete!") end end From b1b90e43124494456c6370ede2ce17b3acfdf319 Mon Sep 17 00:00:00 2001 From: Wendel Fabian Chinsamy Date: Thu, 13 Nov 2025 09:40:11 +0200 Subject: [PATCH 2/2] Set default range to 7 days after the provided IMPORT_DATE env var --- lib/tasks/event.rake | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lib/tasks/event.rake b/lib/tasks/event.rake index 6ce2a38..88b3bd0 100644 --- a/lib/tasks/event.rake +++ b/lib/tasks/event.rake @@ -8,7 +8,7 @@ namespace :event do task import_crossref_event_dois: :environment do date = Date.parse(ENV["IMPORT_DATE"]) start_date = date.beginning_of_day - end_date = (date + 1.month).beginning_of_month.beginning_of_day + end_date = (date + 7.days).beginning_of_day puts("Import date: #{date}") puts("Start date: #{start_date}")