Add TASK_QUEUE_KIND_WORKER_COMMANDS support#9899
Open
rkannan82 wants to merge 5 commits intokannan/ephemeral-partition-propertyfrom
Open
Add TASK_QUEUE_KIND_WORKER_COMMANDS support#9899rkannan82 wants to merge 5 commits intokannan/ephemeral-partition-propertyfrom
rkannan82 wants to merge 5 commits intokannan/ephemeral-partition-propertyfrom
Conversation
rkannan82
changed the title
rkannan82
changed the title
rkannan82
force-pushed
the
kannan/worker-commands-partition-metrics
branch
6 times, most recently
from
7d9ffcf to
a51f55b
Compare
rkannan82
changed the base branch from
main
to
kannan/ephemeral-partition-property
This was referenced Apr 10, 2026
rkannan82
force-pushed
the
kannan/ephemeral-partition-property
branch
from
a163283 to
2b99d6a
Compare
When the SDK sets Kind=TASK_QUEUE_KIND_WORKER_COMMANDS, the server now creates a WorkerCommandsPartition (similar to StickyPartition). Metrics for these partitions get partition=__worker_commands__ and the taskqueue tag is suppressed to __omitted__ to prevent cardinality explosion from per-worker queue names. Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
- Match StickyPartition explicitly instead of using default case - Default to unknownValue for unrecognized partition types - Remove taskQueueBreakdown=false override; BreakdownMetricsByTaskQueue already controls this Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
rkannan82
force-pushed
the
kannan/worker-commands-partition-metrics
branch
from
a51f55b to
d3d045d
Compare
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
1 participant
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
What
Handle the new
TASK_QUEUE_KIND_WORKER_COMMANDStask queue kind by adding aWorkerCommandsPartitiontype totqid(the server-side representation, similar to howStickyPartitionrepresentsTASK_QUEUE_KIND_STICKY).Depends on:
Why
Worker-commands queues have different characteristics from normal and sticky queues — they are ephemeral, single-partition, and used for server-to-worker communication. A distinct partition type allows the server to handle them appropriately: no fan-out/partitioning, distinct
partition=__worker_commands__metric tag, and a foundation for any future kind-specific behavior.How did you test it?
Unit tests covering normal, sticky, and worker-commands partitions with both breakdown-enabled and breakdown-disabled metric configs.
🤖 Generated with Claude Code