Emit worker info with deployed_versions

2019-12-20 16:06:48 +00:00
parent ac6b0a7d47
commit 071d1edae0
1 changed files with 2 additions and 2 deletions
--- a/lib/pipeline/rpc/router.rb
+++ b/lib/pipeline/rpc/router.rb
@@ -169,8 +169,8 @@ module Pipeline::Rpc
        deployed_versions = Hash.new {|h,k| h[k] =  Hash.new {|h,k| h[k] = []} }
        workers.each do |worker|
          puts worker
-          identity = worker["identity"]
-          worker["info"]["deployed_versions"].each do |lang, version|
+          identity = worker[:identity]
+          worker[:info][:deployed_versions].each do |lang, version|
            deployed_versions[lang][version] << identity
          end
        end