diff --git a/lib/solid_queue/processes/registrable.rb b/lib/solid_queue/processes/registrable.rb index 9eddf20e..084e8faf 100644 --- 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