`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)[原始碼]¶

當衍生此類別時覆寫。