`airflow.providers.celery.sensors.celery_queue`¶

Module Contents¶

class airflow.providers.celery.sensors.celery_queue.CeleryQueueSensor(*, celery_queue: str, target_task_id: Optional[str] = None, **kwargs)[source]¶

Bases: airflow.sensors.base.BaseSensorOperator

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.

Parameters

celery_queue (str) -- The name of the Celery queue to wait for.
target_task_id (str) -- Task id for checking

poke(self, context: Dict[str, Any])[source]¶

Was this entry helpful?