Skip to content

Add attributes needed by server to propagate control tasks to worker #711

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
rkannan82 merged 9 commits into from
Apr 6, 2026
Merged

Add attributes needed by server to propagate control tasks to worker #711

Changes from 3 commits
Commits
Show all changes
9 commits
Select commit Hold shift + click to select a range
8115dc2
Add worker_instance_key to RespondWorkflowTaskCompletedRequest
rkannan82 Feb 9, 2026
0033931
Update poll requests
rkannan82 Feb 11, 2026
98350a9
Drop nexus from field name
rkannan82 Feb 11, 2026
c0ad2aa
Merge remote-tracking branch 'origin/master' into kannan/add-worker-i…
rkannan82 Mar 13, 2026
a97e475
Address review: change 'Example' to 'Example tasks' in control queue …
rkannan82 Mar 13, 2026
d5246b9
Merge branch 'master' into kannan/add-worker-instance-key-to-wft-comp…
rkannan82 Apr 6, 2026
90f7ece
Improve worker_control_task_queue proto comments
rkannan82 Apr 6, 2026
0a239a8
Fix field number clash with resource_id in RespondWorkflowTaskComplet…
rkannan82 Apr 6, 2026
eb8aa0d
Merge branch 'master' into kannan/add-worker-instance-key-to-wft-comp…
rkannan82 Apr 6, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
18 changes: 18 additions & 0 deletions temporal/api/workflowservice/v1/request_response.proto
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -262,6 +262,11 @@ message PollWorkflowTaskQueueRequest {
// A unique key for this worker instance, used for tracking worker lifecycle.
// This is guaranteed to be unique, whereas identity is not guaranteed to be unique.
string worker_instance_key = 8;

// The task queue on which the server will send control tasks to this worker.
// Example: Cancel activity, update config, etc.
string worker_control_task_queue = 9;

// Deprecated. Use deployment_options instead.
// Each worker process should provide an ID unique to the specific set of code it is running
// "checksum" in this field name isn't very accurate, it should be though of as an id.
Expand Down Expand Up @@ -381,6 +386,14 @@ message RespondWorkflowTaskCompletedRequest {
// Worker deployment options that user has set in the worker.
temporal.api.deployment.v1.WorkerDeploymentOptions deployment_options = 17;

// A unique key for this worker instance, used for tracking worker lifecycle.
// This is guaranteed to be unique, whereas identity is not guaranteed to be unique.
string worker_instance_key = 18;

// The task queue on which the server will send control tasks to this worker.
// Example: Cancel activity, update config, etc.
string worker_control_task_queue = 19;

// SDK capability details.
message Capabilities {
// True if the SDK can handle speculative workflow task with command events. If true, the
Expand Down Expand Up @@ -444,6 +457,11 @@ message PollActivityTaskQueueRequest {
// A unique key for this worker instance, used for tracking worker lifecycle.
// This is guaranteed to be unique, whereas identity is not guaranteed to be unique.
string worker_instance_key = 8;

// The task queue on which the server will send control tasks to this worker.
// Example: Cancel activity, update config, etc.
string worker_control_task_queue = 9;

temporal.api.taskqueue.v1.TaskQueueMetadata task_queue_metadata = 4;
// Information about this worker's build identifier and if it is choosing to use the versioning
// feature. See the `WorkerVersionCapabilities` docstring for more.
Expand Down
Loading