Try disconnecting before each fork made in the lib

Author: alxckn

lib/puma/plugin/solid_queue.rb

@@ -12,7 +12,7 @@ def start(launcher)
     end
 
     launcher.events.on_booted do
-      @solid_queue_pid = fork do
+      @solid_queue_pid = SolidQueue.safe_fork do
         Thread.new { monitor_puma }
         SolidQueue::Supervisor.start
       end

lib/solid_queue.rb

@@ -73,5 +73,10 @@ def instrument(channel, **options, &block)
     ActiveSupport::Notifications.instrument("#{channel}.solid_queue", **options, &block)
   end
 
+  def safe_fork(&block)
+    Record.clear_all_connections!
+    fork { block.call }
+  end
+
   ActiveSupport.run_load_hooks(:solid_queue, self)
 end

lib/solid_queue/supervisor.rb

@@ -80,9 +80,7 @@ def start_process(configured_process)
           instance.mode = :fork
         end
 
-        Record.clear_all_connections!
-
-        pid = fork do
+        pid = SolidQueue.safe_fork do
           process_instance.start
         end
 

test/integration/puma/plugin_test.rb

@@ -15,7 +15,7 @@ class PluginTest < ActiveSupport::TestCase
           -s
           config.ru
       ]
-      @pid = fork do
+      @pid = SolidQueue.safe_fork do
         exec(*cmd)
       end
     end

test/test_helpers/processes_test_helper.rb

@@ -2,7 +2,7 @@ module ProcessesTestHelper
   private
 
   def run_supervisor_as_fork(**options)
-    fork do
+    SolidQueue.safe_fork do
       SolidQueue::Supervisor.start(**options.with_defaults(skip_recurring: true))
     end
   end