Google Cloud Tasks¶

Cloud Tasks is a fully managed service that allows you to manage the execution, dispatch, and delivery of a large number of distributed tasks. Using Cloud Tasks, you can perform work asynchronously outside of a user or service-to-service request.

For more information about the service visit Cloud Tasks product documentation

Google Cloud Tasks Empty Sensor¶

To sense Queue being empty use TaskQueueEmptySensor

airflow/providers/google/cloud/example_dags/example_cloud_task.py[source]

gcp_cloud_tasks_sensor = TaskQueueEmptySensor(
    project_id=GCP_PROJECT_ID,
    location=GCP_ZONE,
    task_id="gcp_sense_cloud_tasks_empty",
    queue_name=QUEUE_NAME,
)