File tree Expand file tree Collapse file tree 1 file changed +6
-1
lines changed
Expand file tree Collapse file tree 1 file changed +6
-1
lines changed Original file line number Diff line number Diff line change 11# frozen_string_literal: true
22
3+ require "active_support/all"
4+
35namespace :event do
46 desc "Import Crossref DOIs for events created within a date range"
57 # example command: IMPORT_DATE=2025-06-11 bundle exec rake event:import_crossref_event_dois
68 task import_crossref_event_dois : :environment do
79 date = Date . parse ( ENV [ "IMPORT_DATE" ] )
810 start_date = date . beginning_of_day
9- end_date = ( date + 1 ) . beginning_of_day
11+ end_date = ( date + 1 . month ) . beginning_of_month . beginning_of_day
1012
1113 puts ( "Import date: #{ date } " )
1214 puts ( "Start date: #{ start_date } " )
@@ -17,12 +19,15 @@ namespace :event do
1719 . where ( created_at : start_date ...end_date )
1820
1921 puts ( "Number of events: #{ events . count } " )
22+ puts ( "Enqueueing messages to events_other_doi_job..." )
2023
2124 Parallel . each ( events , in_threads : 20 ) do |event |
2225 SqsUtilities . send_events_other_doi_job_message ( {
2326 subj_id : event . subj_id ,
2427 obj_id : event . obj_id ,
2528 } )
2629 end
30+
31+ puts ( "Task complete!" )
2732 end
2833end
You can’t perform that action at this time.
0 commit comments