Fail the import if the check fails

app/jobs/import_account_data_job.rb

@@ -2,6 +2,7 @@ class ImportAccountDataJob < ApplicationJob
   include ActiveJob::Continuable
 
   queue_as :backend
+  discard_on Account::DataTransfer::RecordSet::IntegrityError
 
   def perform(import)
     step :check do |step|

app/models/account/import.rb

@@ -8,7 +8,7 @@ class Account::Import < ApplicationRecord
 
   enum :status, %w[ pending processing completed failed ].index_by(&:itself), default: :pending
 
-  scope :expired, -> { where(completed_at: ...24.hours.ago) }
+  scope :expired, -> { where(completed_at: ...24.hours.ago).or(where(status: :failed, created_at: ...7.days.ago)) }
 
   def self.cleanup
     expired.destroy_all
@@ -26,6 +26,9 @@ class Account::Import < ApplicationRecord
         record_set.check(from: zip, start: last_id, callback: callback)
       end
     end
+  rescue => e
+    mark_as_failed
+    raise e
   end
 
   def process(start: nil, callback: nil)