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

模块内容¶

等待 Celery 队列为空。

class airflow.providers.celery.sensors.celery_queue.CeleryQueueSensor(*, celery_queue, target_task_id=None, **kwargs)[源代码]¶

等待 Celery 队列为空。

默认情况下，为了被认为是空的，队列中不得有任何处于 reserved、 scheduled 或 active 状态的任务。

参数

poke(context)[源代码]¶

在派生此类时覆盖。