Lock the process record before heartbeating

To guard against race conditions of the record being deleted precisely then.
rails · Sep 9, 2024 · 29f297c · 29f297c
1 parent 8744877
commit 29f297c
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