Sha256: 3a6ee102ea491228f86b3cdd8ae1c2fa703fd4350054e29008a6169be8574f51

Contents?: true

Size: 659 Bytes

Versions: 48

Compression:

Stored size: 659 Bytes

Contents

class IngestJob < Hyrax::ApplicationJob
  queue_as Hyrax.config.ingest_queue_name

  after_perform do |job|
    # We want the lastmost Hash, if any.
    opts = job.arguments.reverse.detect { |x| x.is_a? Hash } || {}
    wrapper = job.arguments.first
    ContentNewVersionEventJob.perform_later(wrapper.file_set, wrapper.user) if opts[:notification]
  end

  # @param [JobIoWrapper] wrapper
  # @param [Boolean] notification send the user a notification, used in after_perform callback
  # @see 'config/initializers/hyrax_callbacks.rb'
  # rubocop:disable Lint/UnusedMethodArgument
  def perform(wrapper, notification: false)
    wrapper.ingest_file
  end
end

Version data entries

48 entries across 48 versions & 1 rubygems

Version Path
hyrax-2.9.6 app/jobs/ingest_job.rb
hyrax-2.9.5 app/jobs/ingest_job.rb
hyrax-2.9.4 app/jobs/ingest_job.rb
hyrax-2.9.3 app/jobs/ingest_job.rb
hyrax-2.9.2 app/jobs/ingest_job.rb
hyrax-2.9.1 app/jobs/ingest_job.rb
hyrax-2.9.0 app/jobs/ingest_job.rb
hyrax-2.8.0 app/jobs/ingest_job.rb
hyrax-2.7.2 app/jobs/ingest_job.rb
hyrax-2.7.1 app/jobs/ingest_job.rb
hyrax-2.7.0 app/jobs/ingest_job.rb
hyrax-2.6.0 app/jobs/ingest_job.rb
hyrax-3.0.0.pre.rc1 app/jobs/ingest_job.rb
hyrax-3.0.0.pre.beta3 app/jobs/ingest_job.rb
hyrax-2.5.1 app/jobs/ingest_job.rb
hyrax-2.5.0 app/jobs/ingest_job.rb
hyrax-3.0.0.pre.beta2 app/jobs/ingest_job.rb
hyrax-2.4.1 app/jobs/ingest_job.rb
hyrax-3.0.0.pre.beta1 app/jobs/ingest_job.rb
hyrax-2.4.0 app/jobs/ingest_job.rb