Commit 3bcba221 authored by Sean McGivern's avatar Sean McGivern

Merge branch 'jh-372-jh-config-sidekiq-queues' into 'master'

Add JH config for sidekiq queues

See merge request gitlab-org/gitlab!74666
parents 72065e7b c5256c8e
...@@ -8,6 +8,7 @@ module Gitlab ...@@ -8,6 +8,7 @@ module Gitlab
EE_QUEUE_CONFIG_PATH = 'ee/app/workers/all_queues.yml' EE_QUEUE_CONFIG_PATH = 'ee/app/workers/all_queues.yml'
JH_QUEUE_CONFIG_PATH = 'jh/app/workers/all_queues.yml' JH_QUEUE_CONFIG_PATH = 'jh/app/workers/all_queues.yml'
SIDEKIQ_QUEUES_PATH = 'config/sidekiq_queues.yml' SIDEKIQ_QUEUES_PATH = 'config/sidekiq_queues.yml'
JH_SIDEKIQ_QUEUES_PATH = 'jh/config/sidekiq_queues.yml'
QUEUE_CONFIG_PATHS = [ QUEUE_CONFIG_PATHS = [
FOSS_QUEUE_CONFIG_PATH, FOSS_QUEUE_CONFIG_PATH,
...@@ -100,18 +101,24 @@ module Gitlab ...@@ -100,18 +101,24 @@ module Gitlab
def queues_for_sidekiq_queues_yml def queues_for_sidekiq_queues_yml
namespaces_with_equal_weights = namespaces_with_equal_weights =
workers workers
.reject { |worker| worker.jh? }
.group_by(&:queue_namespace) .group_by(&:queue_namespace)
.map(&:last) .map(&:last)
.select { |workers| workers.map(&:get_weight).uniq.count == 1 } .select { |workers| workers.map(&:get_weight).uniq.count == 1 }
.map(&:first) .map(&:first)
namespaces = namespaces_with_equal_weights.map(&:queue_namespace).to_set namespaces = namespaces_with_equal_weights.map(&:queue_namespace).to_set
remaining_queues = workers.reject { |worker| namespaces.include?(worker.queue_namespace) } remaining_queues = workers.reject { |worker| worker.jh? }.reject { |worker| namespaces.include?(worker.queue_namespace) }
(namespaces_with_equal_weights.map(&:namespace_and_weight) + (namespaces_with_equal_weights.map(&:namespace_and_weight) +
remaining_queues.map(&:queue_and_weight)).sort remaining_queues.map(&:queue_and_weight)).sort
end end
# Override in JH repo
def jh_queues_for_sidekiq_queues_yml
[]
end
# YAML.load_file is OK here as we control the file contents # YAML.load_file is OK here as we control the file contents
def sidekiq_queues_yml_outdated? def sidekiq_queues_yml_outdated?
config_queues = YAML.load_file(SIDEKIQ_QUEUES_PATH)[:queues] config_queues = YAML.load_file(SIDEKIQ_QUEUES_PATH)[:queues]
...@@ -154,3 +161,5 @@ module Gitlab ...@@ -154,3 +161,5 @@ module Gitlab
end end
end end
end end
Gitlab::SidekiqConfig.prepend_mod
...@@ -100,6 +100,10 @@ namespace :gitlab do ...@@ -100,6 +100,10 @@ namespace :gitlab do
queues_and_weights = Gitlab::SidekiqConfig.queues_for_sidekiq_queues_yml queues_and_weights = Gitlab::SidekiqConfig.queues_for_sidekiq_queues_yml
write_yaml(Gitlab::SidekiqConfig::SIDEKIQ_QUEUES_PATH, banner, queues: queues_and_weights) write_yaml(Gitlab::SidekiqConfig::SIDEKIQ_QUEUES_PATH, banner, queues: queues_and_weights)
if Gitlab.jh?
write_yaml(Gitlab::SidekiqConfig::JH_SIDEKIQ_QUEUES_PATH, banner, queues: Gitlab::SidekiqConfig.jh_queues_for_sidekiq_queues_yml)
end
end end
desc 'GitLab | Sidekiq | Validate that sidekiq_queues.yml matches worker definitions' desc 'GitLab | Sidekiq | Validate that sidekiq_queues.yml matches worker definitions'
...@@ -113,6 +117,7 @@ namespace :gitlab do ...@@ -113,6 +117,7 @@ namespace :gitlab do
Then commit and push the changes from: Then commit and push the changes from:
- #{Gitlab::SidekiqConfig::SIDEKIQ_QUEUES_PATH} - #{Gitlab::SidekiqConfig::SIDEKIQ_QUEUES_PATH}
#{"- " + Gitlab::SidekiqConfig::JH_SIDEKIQ_QUEUES_PATH if Gitlab.jh?}
MSG MSG
end end
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment