You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
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.
Celery queue groups for different queues and node assignments
Each worker group creates a separate Deployment assigned to specific nodes and queues
Use case:
Node-specific scheduling: Route certain queues to specialized node pools (GPU, high-memory, etc.)
High-priority vs. low-priority tasks: Allocate more resources to critical queues
Resource-intensive workloads: Dedicate workers with higher memory/CPU to specific queues