Expose workers by language

2020-02-11 13:00:45 +00:00
parent fc2c0bec14
commit c9e953d3e8
1 changed files with 7 additions and 1 deletions
--- a/lib/pipeline/rpc/router.rb
+++ b/lib/pipeline/rpc/router.rb
@@ -204,8 +204,14 @@ module Pipeline::Rpc
            end
          end
        end
+        workers_by_lang = {}
+        deployed_versions.each do |lang,_|
+          wildcard_workers = workers_by_topic["*"]
+          specific_workers = workers_by_topic[lang]
+          workers_by_lang[lang] = wildcard_workers + specific_workers
+        end
        status[worker_class] = {
-          _workers_by_topic: workers_by_topic,
+          _workers_by_lang: workers_by_lang,
          online_workers: worker_ids,
          deployed_versions: deployed_versions
        }