Lock the process record before heartbeating

To guard against race conditions of the record being deleted precisely then.
rails · Sep 11, 2024 · d58c230 · d58c230
1 parent fdf463b
commit d58c230
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/solid_queue/processes/registrable.rb b/lib/solid_queue/processes/registrable.rb
@@ -53,7 +53,7 @@ def stop_heartbeat
       end
 
       def heartbeat
-        process.reload.heartbeat
+        process.with_lock(&:heartbeat)
       rescue ActiveRecord::RecordNotFound
         self.process = nil
         wake_up