airflow-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Sachin <>
Subject How to stop a airflow worker from starting new jobs
Date Tue, 14 May 2019 07:13:26 GMT

I have a airflow setup with Celery executors on kubernetes. The cluster has
many workers pods picking jobs from different queues (rabbitmq).

I want some of my airflow worker pods to continue with jobs which it is
running currently and stop fetching/starting any new jobs from the queue.
On completion of the running job, I will restart the worker pod.

Rest of the airflow worker pods in the cluster will continue with running
jobs and starting new jobs.

Is there a way to achive this?


  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message