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:
Diffstat (limited to 'lib/gitlab/sidekiq_cluster/cli.rb')
-rw-r--r--lib/gitlab/sidekiq_cluster/cli.rb16
1 files changed, 2 insertions, 14 deletions
diff --git a/lib/gitlab/sidekiq_cluster/cli.rb b/lib/gitlab/sidekiq_cluster/cli.rb
index 9490d543dd1..e20834fa912 100644
--- a/lib/gitlab/sidekiq_cluster/cli.rb
+++ b/lib/gitlab/sidekiq_cluster/cli.rb
@@ -22,7 +22,7 @@ module Gitlab
CommandError = Class.new(StandardError)
- def initialize(log_output = STDERR)
+ def initialize(log_output = $stderr)
require_relative '../../../lib/gitlab/sidekiq_logging/json_formatter'
# As recommended by https://github.com/mperham/sidekiq/wiki/Advanced-Options#concurrency
@@ -47,12 +47,6 @@ module Gitlab
option_parser.parse!(argv)
- # Remove with https://gitlab.com/gitlab-com/gl-infra/scalability/-/issues/646
- if @queue_selector && @experimental_queue_selector
- raise CommandError,
- 'You cannot specify --queue-selector and --experimental-queue-selector together'
- end
-
worker_metadatas = SidekiqConfig::CliMethods.worker_metadatas(@rails_path)
worker_queues = SidekiqConfig::CliMethods.worker_queues(@rails_path)
@@ -63,8 +57,7 @@ module Gitlab
# as a worker attribute query, and resolve the queues for the
# queue group using this query.
- # Simplify with https://gitlab.com/gitlab-com/gl-infra/scalability/-/issues/646
- if @queue_selector || @experimental_queue_selector
+ if @queue_selector
SidekiqConfig::CliMethods.query_queues(queues_or_query_string, worker_metadatas)
else
SidekiqConfig::CliMethods.expand_queues(queues_or_query_string.split(','), worker_queues)
@@ -194,11 +187,6 @@ module Gitlab
@queue_selector = queue_selector
end
- # Remove with https://gitlab.com/gitlab-com/gl-infra/scalability/-/issues/646
- opt.on('--experimental-queue-selector', 'DEPRECATED: use --queue-selector-instead') do |experimental_queue_selector|
- @experimental_queue_selector = experimental_queue_selector
- end
-
opt.on('-n', '--negate', 'Run workers for all queues in sidekiq_queues.yml except the given ones') do
@negate_queues = true
end