Emit worker info with status

2019-12-20 15:43:37 +00:00
parent fa91091e7a
commit 44ef7020a6
1 changed files with 1 additions and 1 deletions
--- a/lib/pipeline/rpc/worker_presence.rb
+++ b/lib/pipeline/rpc/worker_presence.rb
@@ -25,7 +25,7 @@ module Pipeline::Rpc
    def list_for(queue_addresses)
      workers = []
      queue_addresses.each do |queue_address|
-        @last_seen[queue_address].each do |worker|
+        @last_seen[queue_address].each do |id, worker|
          workers << worker
        end
      end