airflow.providers.celery.sensors.celery_queue

模块内容

类

CeleryQueueSensor

等待 Celery 队列为空。
class airflow.providers.celery.sensors.celery_queue.CeleryQueueSensor(*, celery_queue, target_task_id=None, **kwargs)[源代码]

基类: airflow.sensors.base.BaseSensorOperator

等待 Celery 队列为空。

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

参数

  • celery_queue ( str ) – 要等待的 Celery 队列的名称。

  • target_task_id ( str | None ) – 用于检查的任务 ID

poke(context)[源代码]

在派生此类时覆盖。

此条目是否有帮助？