CeleryQueueSensor
CeleryWaits for a Celery queue to be empty. By default, in order to be considered empty, the queue must not have any tasks in the reserved, scheduled or active states.
Access Instructions
Install the Celery provider package into your Airflow environment.
Import the module into your DAG file and instantiate it with your desired params.
Parameters
celery_queueRequiredThe name of the Celery queue to wait for.
target_task_idTask id for checking
Documentation
Waits for a Celery queue to be empty. By default, in order to be considered empty, the queue must not have any tasks in the reserved, scheduled or active states.