diff --git a/changelogs/unreleased-ee/fix-sidekiq-cluster-queue-names.yml b/changelogs/unreleased-ee/fix-sidekiq-cluster-queue-names.yml new file mode 100644 index 0000000000000000000000000000000000000000..6b3de2bda38daeb1c25c2aca8b71b95f5219a231 --- /dev/null +++ b/changelogs/unreleased-ee/fix-sidekiq-cluster-queue-names.yml @@ -0,0 +1,4 @@ +--- +title: Fix sidekiq cluster mishandling of queue names +merge_request: 1117 +author: diff --git a/lib/gitlab/sidekiq_cluster.rb b/lib/gitlab/sidekiq_cluster.rb index b52101e035991b4db5cdfda1174c3be21169db5c..7974478cb46dd1834ccfb7746ab3df34698c2edc 100644 --- a/lib/gitlab/sidekiq_cluster.rb +++ b/lib/gitlab/sidekiq_cluster.rb @@ -70,7 +70,7 @@ def self.start(queues, env, directory = Dir.pwd) # # Returns the PID of the started process. def self.start_sidekiq(queues, env, directory = Dir.pwd) - switches = queues.map { |q| "-q #{q},1" } + switches = queues.map { |q| "-q#{q},1" } pid = Process.spawn( { 'ENABLE_SIDEKIQ_CLUSTER' => '1' },