Welcome to mirror list, hosted at ThFree Co, Russian Federation.

gitlab.com/gitlab-org/gitlab-foss.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorGrzegorz Bizon <grzesiek.bizon@gmail.com>2017-08-21 14:49:57 +0300
committerGrzegorz Bizon <grzesiek.bizon@gmail.com>2017-08-21 14:49:57 +0300
commit48776f2786d22cecab97417141d43060c6cdee26 (patch)
tree548fa53f25eff1a41267bc2eae61434309ede3b3 /app/workers/concerns
parentce274fd61bbe11c7a1353bff2176273e9b30e197 (diff)
Simplify pipeline sidekiq queues naming scheme
Diffstat (limited to 'app/workers/concerns')
-rw-r--r--app/workers/concerns/pipeline_queue.rb8
1 files changed, 4 insertions, 4 deletions
diff --git a/app/workers/concerns/pipeline_queue.rb b/app/workers/concerns/pipeline_queue.rb
index ed882e3ecef..ddf45b91345 100644
--- a/app/workers/concerns/pipeline_queue.rb
+++ b/app/workers/concerns/pipeline_queue.rb
@@ -5,14 +5,14 @@ module PipelineQueue
extend ActiveSupport::Concern
included do
- sidekiq_options queue: 'pipelines-default'
+ sidekiq_options queue: 'pipeline_default'
end
class_methods do
- def enqueue_in(queue:, group:)
- raise ArgumentError if queue.empty? || group.empty?
+ def enqueue_in(group:)
+ raise ArgumentError, 'Unspecified queue group!' if group.empty?
- sidekiq_options queue: "pipelines-#{queue}-#{group}"
+ sidekiq_options queue: "pipeline_#{group}"
end
end
end