diff --git a/internal/internal_worker_heartbeat.go b/internal/internal_worker_heartbeat.go index 86c0c35fd..d8f96e1a8 100644 --- a/internal/internal_worker_heartbeat.go +++ b/internal/internal_worker_heartbeat.go @@ -167,6 +167,7 @@ func (hw *sharedNamespaceWorker) sendHeartbeats() error { _, err := hw.client.recordWorkerHeartbeat(hw.heartbeatCtx, &workflowservice.RecordWorkerHeartbeatRequest{ Namespace: hw.namespace, + Identity: hw.client.identity, WorkerHeartbeat: heartbeats, })