Skip to content

Increase the date range for the crossref other doi rake #77

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
wendelfabianchinsamy wants to merge 2 commits into from
Closed

Increase the date range for the crossref other doi rake #77

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
45aad43
Increase the date range for the crossref other doi rake
wendelfabianchinsamy Nov 12, 2025
b1b90e4
Set default range to 7 days after the provided IMPORT_DATE env var
wendelfabianchinsamy Nov 13, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 6 additions & 1 deletion lib/tasks/event.rake
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -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 + 7.days).beginning_of_day

puts("Import date: #{date}")
puts("Start date: #{start_date}")
Expand All @@ -17,12 +19,15 @@ 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({
subj_id: event.subj_id,
obj_id: event.obj_id,
})
end

puts("Task complete!")
end
end