Waits for a Celery queue to be empty. By default, in order to be considered
- class airflow.providers.celery.sensors.celery_queue.CeleryQueueSensor(*, celery_queue, target_task_id=None, **kwargs)¶
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
- poke(self, context)¶
Function that the sensors defined while deriving this class should override.