Sha256: ffbd05167c2ce1dcb79c99956931add526382c061a88eb29c61caef6949ac53e
Contents?: true
Size: 1.25 KB
Versions: 6
Compression:
Stored size: 1.25 KB
Contents
# frozen_string_literal: true
module Bulkrax
class ImportWorkJob < ApplicationJob
queue_as :import
# rubocop:disable Rails/SkipsModelValidations
def perform(*args)
entry = Entry.find(args[0])
entry.build
if entry.status == "Complete"
ImporterRun.find(args[1]).increment!(:processed_records)
ImporterRun.find(args[1]).decrement!(:enqueued_records) unless ImporterRun.find(args[1]).enqueued_records <= 0 # rubocop:disable Style/IdenticalConditionalBranches
else
# do not retry here because whatever parse error kept you from creating a work will likely
# keep preventing you from doing so.
ImporterRun.find(args[1]).increment!(:failed_records)
ImporterRun.find(args[1]).decrement!(:enqueued_records) unless ImporterRun.find(args[1]).enqueued_records <= 0 # rubocop:disable Style/IdenticalConditionalBranches
end
entry.save!
entry.importer.current_run = ImporterRun.find(args[1])
entry.importer.record_status
rescue Bulkrax::CollectionsCreatedError
reschedule(args[0], args[1])
end
# rubocop:enable Rails/SkipsModelValidations
def reschedule(entry_id, run_id)
ImportWorkJob.set(wait: 1.minute).perform_later(entry_id, run_id)
end
end
end
Version data entries
6 entries across 6 versions & 1 rubygems