airflow.providers.celery.sensors.celery_queue

Module Contents

Classes

CeleryQueueSensor

Waits for a Celery queue to be empty.
class airflow.providers.celery.sensors.celery_queue.CeleryQueueSensor(*, celery_queue, target_task_id=None, **kwargs)[source]

Bases: airflow.sensors.base.BaseSensorOperator

Waits for a Celery queue to be empty.

By default, in order to be considered empty, the queue must not have any tasks in the reserved, scheduled or active states.

Parameters

  • celery_queue (str) – The name of the Celery queue to wait for.

  • target_task_id (str | None) – Task id for checking

poke(context)[source]

Function defined by the sensors while deriving this class should override.

Was this entry helpful?