Skip to content

Add support for multiple Celery worker groups with queue-specific configurations #56591

@HsiuChuanHsu

Description

@HsiuChuanHsu

Description

We are using Apache Airflow with the Celery Executor and need to configure the system to allow tasks in different queues to be executed on specific nodes.

The goal is to achieve fine-grained control over task distribution by assigning queues to designated worker nodes.

Use case/motivation

Assign each queue to run on specific worker nodes to optimize resource allocation and task execution.

  1. Celery queue groups for different queues and node assignments
  2. Each worker group creates a separate Deployment assigned to specific nodes and queues

Use case:

  1. Node-specific scheduling: Route certain queues to specialized node pools (GPU, high-memory, etc.)
  2. High-priority vs. low-priority tasks: Allocate more resources to critical queues
  3. Resource-intensive workloads: Dedicate workers with higher memory/CPU to specific queues

Related issues

No response

Are you willing to submit a PR?

  • Yes I am willing to submit a PR!

Code of Conduct

Metadata

Metadata

Assignees

No one assigned

    Labels

    kind:featureFeature Requestsneeds-triagelabel for new issues that we didn't triage yet

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions