app/jobs/ingest_from_source_job.rb
# frozen_string_literal: true
# Abstract job which performs batch ingest from a source
class IngestFromSourceJob < Hyrax::ApplicationJob
queue_as Hyrax.config.ingest_queue_name
def perform(user, selected_filepaths)
@user = user
start = Time.now
Rails.logger.info("Starting ingest job for #{source}")
ingest_service.process_packages(selected_filepaths)
Rails.logger.debug("Ingest job for #{source} completed in #{Time.now - start}")
end
def ingest_status_service
@status_service ||= Tasks::IngestStatusService.status_service_for_source(source)
end
end