Ignore processes option when running in async mode

Author: rosa

lib/solid_queue/configuration.rb

@@ -17,7 +17,8 @@ class Configuration
       recurring_tasks: []
     }
 
-    def initialize(load_from: nil)
+    def initialize(mode: :fork, load_from: nil)
+      @mode = mode.to_s.inquiry
       @raw_config = config_from(load_from)
     end
 
@@ -27,7 +28,11 @@ def processes
 
     def workers
       workers_options.flat_map do |worker_options|
-        processes = worker_options.fetch(:processes, WORKER_DEFAULTS[:processes])
+        processes = if mode.fork?
+          worker_options.fetch(:processes, WORKER_DEFAULTS[:processes])
+        else
+          WORKER_DEFAULTS[:processes]
+        end
         processes.times.map { Worker.new(**worker_options.with_defaults(WORKER_DEFAULTS)) }
       end
     end
@@ -45,7 +50,7 @@ def max_number_of_threads
     end
 
     private
-      attr_reader :raw_config
+      attr_reader :raw_config, :mode
 
       DEFAULT_CONFIG_FILE_PATH = "config/solid_queue.yml"
 

lib/solid_queue/supervisor.rb

@@ -7,7 +7,7 @@ class Supervisor < Processes::Base
     class << self
       def start(mode: :fork, load_configuration_from: nil)
         SolidQueue.supervisor = true
-        configuration = Configuration.new(load_from: load_configuration_from)
+        configuration = Configuration.new(mode: mode, load_from: load_configuration_from)
 
         klass = mode == :fork ? ForkSupervisor : AsyncSupervisor
         klass.new(configuration).tap(&:start)

test/unit/configuration_test.rb

@@ -57,4 +57,14 @@ class ConfigurationTest < ActiveSupport::TestCase
     assert_equal [ "background" ], configuration.workers.flat_map(&:queues).uniq
     assert_equal [ 10 ], configuration.workers.map(&:polling_interval).uniq
   end
+
+  test "ignore processes option on async mode" do
+    background_worker = { queues: "background", polling_interval: 10, processes: 3 }
+    config_as_hash = { workers: [ background_worker ] }
+    configuration = SolidQueue::Configuration.new(mode: :async, load_from: config_as_hash)
+
+    assert_equal 1, configuration.workers.count
+    assert_equal [ "background" ], configuration.workers.first.queues
+    assert_equal 10, configuration.workers.first.polling_interval
+  end
 end