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]¶

派生此類時重寫此方法。

此條目有幫助嗎？