Respond to upstream: nexus start sync failure

temporalio/api/worker/v1/message_pb2.pyi

@@ -132,13 +132,23 @@ class WorkerHostInfo(google.protobuf.message.Message):
     DESCRIPTOR: google.protobuf.descriptor.Descriptor
 
     HOST_NAME_FIELD_NUMBER: builtins.int
+    PROCESS_KEY_FIELD_NUMBER: builtins.int
     PROCESS_ID_FIELD_NUMBER: builtins.int
     CURRENT_HOST_CPU_USAGE_FIELD_NUMBER: builtins.int
     CURRENT_HOST_MEM_USAGE_FIELD_NUMBER: builtins.int
     host_name: builtins.str
     """Worker host identifier."""
+    process_key: builtins.str
+    """Worker process identifier. This id should be unique for all _processes_
+    running workers in the namespace, and should be shared by all workers
+    in the same process.
+    This will be used to build the worker command nexus task queue name:
+    "temporal-sys/worker-commands/{process_key}"
+    """
     process_id: builtins.str
-    """Worker process identifier, should be unique for the host."""
+    """Worker process identifier. Unlike process_key, this id only needs to be unique
+    within one host (so using e.g. a unix pid would be appropriate).
+    """
     current_host_cpu_usage: builtins.float
     """System used CPU as a float in the range [0.0, 1.0] where 1.0 is defined as all
     cores on the host pegged.
@@ -151,6 +161,7 @@ class WorkerHostInfo(google.protobuf.message.Message):
         self,
         *,
         host_name: builtins.str = ...,
+        process_key: builtins.str = ...,
         process_id: builtins.str = ...,
         current_host_cpu_usage: builtins.float = ...,
         current_host_mem_usage: builtins.float = ...,
@@ -166,6 +177,8 @@ class WorkerHostInfo(google.protobuf.message.Message):
             b"host_name",
             "process_id",
             b"process_id",
+            "process_key",
+            b"process_key",
         ],
     ) -> None: ...
 

temporalio/api/workflowservice/v1/request_response_pb2.pyi

@@ -7006,7 +7006,11 @@ class PollNexusTaskQueueRequest(google.protobuf.message.Message):
     ) -> temporalio.api.deployment.v1.message_pb2.WorkerDeploymentOptions:
         """Worker deployment options that user has set in the worker."""
     @property
-    def worker_heartbeat(self) -> temporalio.api.worker.v1.message_pb2.WorkerHeartbeat:
+    def worker_heartbeat(
+        self,
+    ) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[
+        temporalio.api.worker.v1.message_pb2.WorkerHeartbeat
+    ]:
         """Worker info to be sent to the server."""
     def __init__(
         self,
@@ -7018,7 +7022,9 @@ class PollNexusTaskQueueRequest(google.protobuf.message.Message):
         | None = ...,
         deployment_options: temporalio.api.deployment.v1.message_pb2.WorkerDeploymentOptions
         | None = ...,
-        worker_heartbeat: temporalio.api.worker.v1.message_pb2.WorkerHeartbeat
+        worker_heartbeat: collections.abc.Iterable[
+            temporalio.api.worker.v1.message_pb2.WorkerHeartbeat
+        ]
         | None = ...,
     ) -> None: ...
     def HasField(
@@ -7028,8 +7034,6 @@ class PollNexusTaskQueueRequest(google.protobuf.message.Message):
             b"deployment_options",
             "task_queue",
             b"task_queue",
-            "worker_heartbeat",
-            b"worker_heartbeat",
             "worker_version_capabilities",
             b"worker_version_capabilities",
         ],
@@ -9363,19 +9367,19 @@ class RecordWorkerHeartbeatRequest(google.protobuf.message.Message):
     @property
     def worker_heartbeat(
         self,
-    ) -> temporalio.api.worker.v1.message_pb2.WorkerHeartbeat: ...
+    ) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[
+        temporalio.api.worker.v1.message_pb2.WorkerHeartbeat
+    ]: ...
     def __init__(
         self,
         *,
         namespace: builtins.str = ...,
         identity: builtins.str = ...,
-        worker_heartbeat: temporalio.api.worker.v1.message_pb2.WorkerHeartbeat
+        worker_heartbeat: collections.abc.Iterable[
+            temporalio.api.worker.v1.message_pb2.WorkerHeartbeat
+        ]
         | None = ...,
     ) -> None: ...
-    def HasField(
-        self,
-        field_name: typing_extensions.Literal["worker_heartbeat", b"worker_heartbeat"],
-    ) -> builtins.bool: ...
     def ClearField(
         self,
         field_name: typing_extensions.Literal[