Emit worker info with deployed_versions

2019-12-20 16:10:31 +00:00
parent c4e5147313
commit 2741fe6f58
1 changed files with 4 additions and 2 deletions
--- a/lib/pipeline/rpc/router.rb
+++ b/lib/pipeline/rpc/router.rb
@@ -169,8 +169,10 @@ module Pipeline::Rpc
        deployed_versions = Hash.new {|h,k| h[k] =  Hash.new {|h,k| h[k] = []} }
        workers.each do |worker|
          identity = worker[:identity]
-          worker[:info]["deployed_versions"].each do |lang, version|
-            deployed_versions[lang][version] << identity
+          worker[:info]["deployed_versions"].each do |lang, versions|
+            versions.each do |version|
+              deployed_versions[lang][version] << identity
+            end
          end
        end
        status[worker_class] = {