Skip to content

Commit a1cc63b

Browse files
dandavisontconley1428
authored andcommitted
Respond to upstream: nexus start sync failure (#1026)
* Update core * Update protos * Respond to upstream core proto / api change: fail on sync start * Update bridge Cargo.lock
1 parent a098c8b commit a1cc63b

File tree

10 files changed

+89
-65
lines changed

10 files changed

+89
-65
lines changed

temporalio/api/worker/v1/message_pb2.py

Lines changed: 7 additions & 7 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

temporalio/api/worker/v1/message_pb2.pyi

Lines changed: 14 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -132,13 +132,23 @@ class WorkerHostInfo(google.protobuf.message.Message):
132132
DESCRIPTOR: google.protobuf.descriptor.Descriptor
133133

134134
HOST_NAME_FIELD_NUMBER: builtins.int
135+
PROCESS_KEY_FIELD_NUMBER: builtins.int
135136
PROCESS_ID_FIELD_NUMBER: builtins.int
136137
CURRENT_HOST_CPU_USAGE_FIELD_NUMBER: builtins.int
137138
CURRENT_HOST_MEM_USAGE_FIELD_NUMBER: builtins.int
138139
host_name: builtins.str
139140
"""Worker host identifier."""
141+
process_key: builtins.str
142+
"""Worker process identifier. This id should be unique for all _processes_
143+
running workers in the namespace, and should be shared by all workers
144+
in the same process.
145+
This will be used to build the worker command nexus task queue name:
146+
"temporal-sys/worker-commands/{process_key}"
147+
"""
140148
process_id: builtins.str
141-
"""Worker process identifier, should be unique for the host."""
149+
"""Worker process identifier. Unlike process_key, this id only needs to be unique
150+
within one host (so using e.g. a unix pid would be appropriate).
151+
"""
142152
current_host_cpu_usage: builtins.float
143153
"""System used CPU as a float in the range [0.0, 1.0] where 1.0 is defined as all
144154
cores on the host pegged.
@@ -151,6 +161,7 @@ class WorkerHostInfo(google.protobuf.message.Message):
151161
self,
152162
*,
153163
host_name: builtins.str = ...,
164+
process_key: builtins.str = ...,
154165
process_id: builtins.str = ...,
155166
current_host_cpu_usage: builtins.float = ...,
156167
current_host_mem_usage: builtins.float = ...,
@@ -166,6 +177,8 @@ class WorkerHostInfo(google.protobuf.message.Message):
166177
b"host_name",
167178
"process_id",
168179
b"process_id",
180+
"process_key",
181+
b"process_key",
169182
],
170183
) -> None: ...
171184

temporalio/api/workflowservice/v1/request_response_pb2.py

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

temporalio/api/workflowservice/v1/request_response_pb2.pyi

Lines changed: 14 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -7006,7 +7006,11 @@ class PollNexusTaskQueueRequest(google.protobuf.message.Message):
70067006
) -> temporalio.api.deployment.v1.message_pb2.WorkerDeploymentOptions:
70077007
"""Worker deployment options that user has set in the worker."""
70087008
@property
7009-
def worker_heartbeat(self) -> temporalio.api.worker.v1.message_pb2.WorkerHeartbeat:
7009+
def worker_heartbeat(
7010+
self,
7011+
) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[
7012+
temporalio.api.worker.v1.message_pb2.WorkerHeartbeat
7013+
]:
70107014
"""Worker info to be sent to the server."""
70117015
def __init__(
70127016
self,
@@ -7018,7 +7022,9 @@ class PollNexusTaskQueueRequest(google.protobuf.message.Message):
70187022
| None = ...,
70197023
deployment_options: temporalio.api.deployment.v1.message_pb2.WorkerDeploymentOptions
70207024
| None = ...,
7021-
worker_heartbeat: temporalio.api.worker.v1.message_pb2.WorkerHeartbeat
7025+
worker_heartbeat: collections.abc.Iterable[
7026+
temporalio.api.worker.v1.message_pb2.WorkerHeartbeat
7027+
]
70227028
| None = ...,
70237029
) -> None: ...
70247030
def HasField(
@@ -7028,8 +7034,6 @@ class PollNexusTaskQueueRequest(google.protobuf.message.Message):
70287034
b"deployment_options",
70297035
"task_queue",
70307036
b"task_queue",
7031-
"worker_heartbeat",
7032-
b"worker_heartbeat",
70337037
"worker_version_capabilities",
70347038
b"worker_version_capabilities",
70357039
],
@@ -9363,19 +9367,19 @@ class RecordWorkerHeartbeatRequest(google.protobuf.message.Message):
93639367
@property
93649368
def worker_heartbeat(
93659369
self,
9366-
) -> temporalio.api.worker.v1.message_pb2.WorkerHeartbeat: ...
9370+
) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[
9371+
temporalio.api.worker.v1.message_pb2.WorkerHeartbeat
9372+
]: ...
93679373
def __init__(
93689374
self,
93699375
*,
93709376
namespace: builtins.str = ...,
93719377
identity: builtins.str = ...,
9372-
worker_heartbeat: temporalio.api.worker.v1.message_pb2.WorkerHeartbeat
9378+
worker_heartbeat: collections.abc.Iterable[
9379+
temporalio.api.worker.v1.message_pb2.WorkerHeartbeat
9380+
]
93739381
| None = ...,
93749382
) -> None: ...
9375-
def HasField(
9376-
self,
9377-
field_name: typing_extensions.Literal["worker_heartbeat", b"worker_heartbeat"],
9378-
) -> builtins.bool: ...
93799383
def ClearField(
93809384
self,
93819385
field_name: typing_extensions.Literal[

temporalio/bridge/Cargo.lock

Lines changed: 11 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

0 commit comments

Comments
 (0)