Add SolidQueue.supervisor? to signal that we're running as a SQ super…

…visor process We only want to do certain things in that case, such as emitting global metrics.
rails · Nov 1, 2023 · 5390165 · 5390165
1 parent b9e8228
commit 5390165
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/lib/solid_queue.rb b/lib/solid_queue.rb
@@ -28,4 +28,9 @@ module SolidQueue
   mattr_accessor :shutdown_timeout, default: 5.seconds
 
   mattr_accessor :supervisor_pidfile
+  mattr_accessor :supervisor, default: false
+
+  def self.supervisor?
+    supervisor
+  end
 end
diff --git a/lib/solid_queue/supervisor.rb b/lib/solid_queue/supervisor.rb
@@ -6,6 +6,7 @@ class Supervisor
 
     class << self
       def start(mode: :work, load_configuration_from: nil)
+        SolidQueue.supervisor = true
         configuration = Configuration.new(mode: mode, load_from: load_configuration_from)
 
         new(configuration.runners).start