Sha256: 993d24334e7b04927c92684983ba511aa8b571e1ab0c72997550ed0b42201ed5
Contents?: true
Size: 812 Bytes
Versions: 22
Compression:
Stored size: 812 Bytes
Contents
# frozen_string_literal: true
module Bulkrax
class ScheduleRelationshipsJob < ApplicationJob
def perform(importer_id:)
importer = Importer.find(importer_id)
pending_num = importer.entries.left_outer_joins(:latest_status)
.where('bulkrax_statuses.status_message IS NULL ').count
return reschedule(importer_id) unless pending_num.zero?
importer.last_run.parents.each do |parent_id|
Bulkrax.relationship_job_class.constantize.perform_later(parent_identifier: parent_id,
importer_run_id: importer.last_run.id)
end
end
def reschedule(importer_id)
ScheduleRelationshipsJob.set(wait: 5.minutes).perform_later(importer_id: importer_id)
false
end
end
end
Version data entries
22 entries across 22 versions & 1 rubygems