airflow.providers.celery.sensors.celery_queue¶

类¶

CeleryQueueSensor

等待 Celery 队列为空。

模块内容¶

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

基类：airflow.sensors.base.BaseSensorOperator

等待 Celery 队列为空。

默认情况下，要被视为空，队列中必须没有处于 reserved（保留）、scheduled（计划中）或 active（活跃）状态的任务。

参数：

celery_queue (str) – 要等待的 Celery 队列名称。
target_task_id (str | None) – 用于检查的任务 ID。

celery_queue[source]¶

target_task_id = None[source]¶

poke(context)[source]¶

派生此类时重写此方法。

此条目有帮助吗？