Emit worker info with deployed_versions

2019-12-20 16:18:27 +00:00
parent 9170fde9e6
commit aa5022d790
1 changed files with 4 additions and 2 deletions
--- a/lib/pipeline/rpc/router.rb
+++ b/lib/pipeline/rpc/router.rb
@@ -167,8 +167,10 @@ module Pipeline::Rpc
        end
        workers =  @worker_presence.list_for(addresses)
        deployed_versions = Hash.new {|h,k| h[k] =  Hash.new {|h,k| h[k] = []} }
-        target_versions.each do |lang, version|
-          deployed_versions[lang][version] = []
+        target_versions.each do |lang, versions|
+          versions.each do |version|
+            deployed_versions[lang][version] = []
+          end
        end
        worker_ids = []
        workers.each do |worker|