Skip to content

Add queue parameter to edge list-workers subcommand#70436

Open
shubhamraj-git wants to merge 1 commit into
apache:mainfrom
shubhamraj-git:add-queue
Open

Add queue parameter to edge list-workers subcommand#70436
shubhamraj-git wants to merge 1 commit into
apache:mainfrom
shubhamraj-git:add-queue

Conversation

@shubhamraj-git

@shubhamraj-git shubhamraj-git commented Jul 25, 2026

Copy link
Copy Markdown
Contributor

airflow edge list-workers could filter by worker name and state, but not by queue. This adds a -q/--queue flag that lists only workers serving a given queue (exact match).

airflow edge list-workers --queue gpu

image

Was generative AI tooling used to co-author this PR?

  • Yes (Opus 4.8)

@boring-cyborg boring-cyborg Bot added area:providers kind:documentation provider:edge Edge Executor / Worker (AIP-69) / edge3 labels Jul 25, 2026
@shubhamraj-git shubhamraj-git changed the title add queue paarmeter to list-workers Add queue parameter to edge list-workers subcommand Jul 25, 2026
@shubhamraj-git shubhamraj-git added the ready for maintainer review Set after triaging when all criteria pass. label Jul 25, 2026
@shubhamraj-git shubhamraj-git added this to the Airflow 3.3.1 milestone Jul 25, 2026
@shubhamraj-git shubhamraj-git added the backport-to-v3-3-test Backport to v3-3-test label Jul 25, 2026
@dheerajturaga

Copy link
Copy Markdown
Member

@shubhamraj-git, milestone and backport labels are not needed for providers as they are generally cut periodically from main directly.

@dheerajturaga dheerajturaga left a comment

Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Awesome! thanks for the enhancement. It works as advertised

help="The number of worker processes",
default=conf.getint("edge", "worker_concurrency", fallback=8),
)
ARG_QUEUES = Arg(

Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

On second pass, there is already a ARG_QUEUES , why not re-use this instead? In case user wants to provide a list of queues to filter by?

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

area:providers backport-to-v3-3-test Backport to v3-3-test kind:documentation provider:edge Edge Executor / Worker (AIP-69) / edge3 ready for maintainer review Set after triaging when all criteria pass.

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants