Sha256: 0e83cd27f74e1fe01b383cee484db92e19f98c32558df912579bc0309d5425e5

Contents?: true

Size: 810 Bytes

Versions: 10

Compression:

Stored size: 810 Bytes

Contents

# frozen_string_literal: true

module Bulkrax
  class DeleteJob < ApplicationJob
    queue_as Bulkrax.config.ingest_queue_name

    def perform(entry, importer_run)
      user = importer_run.importer.user
      entry.factory.delete(user)

      # rubocop:disable Rails/SkipsModelValidations
      ImporterRun.increment_counter(:deleted_records, importer_run.id)
      ImporterRun.decrement_counter(:enqueued_records, importer_run.id)
      # rubocop:enable Rails/SkipsModelValidations
      entry.save!
      entry.importer.current_run = ImporterRun.find(importer_run.id)
      entry.importer.record_status
      entry.set_status_info("Deleted", ImporterRun.find(importer_run.id))
    rescue => e
      entry.set_status_info(e)
      # this causes caught exception to be reraised
      raise
    end
  end
end

Version data entries

10 entries across 10 versions & 1 rubygems

Version Path
bulkrax-9.0.2 app/jobs/bulkrax/delete_job.rb
bulkrax-9.0.1 app/jobs/bulkrax/delete_job.rb
bulkrax-9.0.0 app/jobs/bulkrax/delete_job.rb
bulkrax-8.2.3 app/jobs/bulkrax/delete_job.rb
bulkrax-8.2.2 app/jobs/bulkrax/delete_job.rb
bulkrax-8.3.0 app/jobs/bulkrax/delete_job.rb
bulkrax-8.2.1 app/jobs/bulkrax/delete_job.rb
bulkrax-8.2.0 app/jobs/bulkrax/delete_job.rb
bulkrax-8.1.0 app/jobs/bulkrax/delete_job.rb
bulkrax-8.0.0 app/jobs/bulkrax/delete_job.rb