Periodically emit channel/topic information from worker

2019-12-20 15:03:31 +00:00
parent 944a0ad0f2
commit a21f7a26bb
1 changed files with 2 additions and 0 deletions
--- a/lib/pipeline/rpc/worker/daemon.rb
+++ b/lib/pipeline/rpc/worker/daemon.rb
@@ -85,6 +85,8 @@ module Pipeline::Rpc::Worker
          sleep 2
          msg = {
            msg_type: "worker_heartbeat",
+            channel: @channel,
+            topics: @topics,
            identity: identity,
            workqueue_addresses: workqueue_addresses,
            deployed_versions: environment.list_deployed_containers