Release orphaned executions just once, before booting the supervisor

Instead of periodically.

Author: rosa

lib/solid_queue/supervisor/maintenance.rb

@@ -1,30 +1,34 @@
 module SolidQueue
   module Supervisor::Maintenance
+    extend ActiveSupport::Concern
+
+    included do
+      after_boot :release_orphaned_executions
+    end
+
     private
+      def launch_maintenance_task
+        @maintenance_task = Concurrent::TimerTask.new(run_now: true, execution_interval: SolidQueue.process_alive_threshold) do
+          prune_dead_processes
+        end
 
-    def launch_maintenance_task
-      @maintenance_task = Concurrent::TimerTask.new(run_now: true, execution_interval: SolidQueue.process_alive_threshold) do
-        prune_dead_processes
-        release_orphaned_executions
-      end
+        @maintenance_task.add_observer do |_, _, error|
+          handle_thread_error(error) if error
+        end
 
-      @maintenance_task.add_observer do |_, _, error|
-        handle_thread_error(error) if error
+        @maintenance_task.execute
       end
 
-      @maintenance_task.execute
-    end
-
-    def stop_maintenance_task
-      @maintenance_task&.shutdown
-    end
+      def stop_maintenance_task
+        @maintenance_task&.shutdown
+      end
 
-    def prune_dead_processes
-      wrap_in_app_executor { SolidQueue::Process.prune }
-    end
+      def prune_dead_processes
+        wrap_in_app_executor { SolidQueue::Process.prune }
+      end
 
-    def release_orphaned_executions
-      wrap_in_app_executor { SolidQueue::ClaimedExecution.orphaned.release_all }
-    end
+      def release_orphaned_executions
+        wrap_in_app_executor { SolidQueue::ClaimedExecution.orphaned.release_all }
+      end
   end
 end