From 48c06d1121687c730fb09b8379008898f9b53584 Mon Sep 17 00:00:00 2001
From: Charles Care <c.p.care@gmail.com>
Date: Fri, 20 Dec 2019 15:57:17 +0000
Subject: [PATCH] Emit worker info with deployed_versions

---
 lib/pipeline/rpc/router.rb | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/lib/pipeline/rpc/router.rb b/lib/pipeline/rpc/router.rb
index d988e3a..40404ae 100644
--- a/lib/pipeline/rpc/router.rb
+++ b/lib/pipeline/rpc/router.rb
@@ -166,10 +166,17 @@ module Pipeline::Rpc
           addresses << backend.public_address
         end
         workers =  @worker_presence.list_for(addresses)
+        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
+          end
+        end
         status[worker_class] = {
           target_versions: versions,
           queue_addresses: addresses,
-          workers: workers
+          deployed_versions: deployed_versions
         }
       end
       status