diff --git a/app/models/good_job/base_execution.rb b/app/models/good_job/base_execution.rb
index 36008daf..f413821f 100644
--- a/app/models/good_job/base_execution.rb
+++ b/app/models/good_job/base_execution.rb
@@ -481,11 +481,7 @@ def perform(lock_id:)
           end
         end
 
-        job_attributes = if self.class.columns_hash.key?("locked_by_id")
-                           { locked_by_id: nil, locked_at: nil }
-                         else
-                           {}
-                         end
+        job_attributes = { locked_by_id: nil, locked_at: nil }
 
         job_error = result.handled_error || result.unhandled_error
         if job_error
diff --git a/app/models/good_job/process.rb b/app/models/good_job/process.rb
index 5340a9ce..7bf061b3 100644
--- a/app/models/good_job/process.rb
+++ b/app/models/good_job/process.rb
@@ -26,7 +26,7 @@ class Process < BaseRecord
     self.table_name = 'good_job_processes'
 
     has_many :locked_jobs, class_name: "GoodJob::Job", foreign_key: :locked_by_id, inverse_of: :locked_by_process, dependent: nil
-    after_destroy { locked_jobs.update_all(locked_by_id: nil) if GoodJob::Job.columns_hash.key?("locked_by_id") } # rubocop:disable Rails/SkipsModelValidations
+    after_destroy { locked_jobs.update_all(locked_by_id: nil) } # rubocop:disable Rails/SkipsModelValidations
 
     # Processes that are active and locked.
     # @!method active
@@ -51,7 +51,7 @@ class Process < BaseRecord
     # Deletes all inactive process records.
     def self.cleanup
       inactive.find_each do |process|
-        GoodJob::Job.where(locked_by_id: process.id).update_all(locked_by_id: nil, locked_at: nil) if GoodJob::Job.columns_hash.key?("locked_by_id") # rubocop:disable Rails/SkipsModelValidations
+        GoodJob::Job.where(locked_by_id: process.id).update_all(locked_by_id: nil, locked_at: nil) # rubocop:disable Rails/SkipsModelValidations
         process.delete
       end
     end