Contents

class CreateWorkJob < ActiveJob::Base
  queue_as :ingest

  before_enqueue do |job|
    log = job.arguments.last
    log.pending_job(self)
  end

  # This copies metadata from the passed in attribute to all of the works that
  # are members of the given upload set
  def perform(user, attributes, log)
    log.performing!
    work = GenericWork.new
    actor = work_actor(work, user)
    status = actor.create(attributes)
    return log.success! if status
    log.fail!(work.errors.full_messages.join(' '))
  end

  private

    def work_actor(work, user)
      CurationConcerns::CurationConcern.actor(work, user)
    end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
sufia-7.0.0.beta4	app/jobs/create_work_job.rb
sufia-7.0.0.beta3	app/jobs/create_work_job.rb
sufia-7.0.0.beta2	app/jobs/create_work_job.rb
sufia-7.0.0.beta1	app/jobs/create_work_job.rb