Google Cloud Tasks¶

Cloud Tasks 是一项完全托管的服务，可用于管理大量分布式任务的执行、调度和交付。使用 Cloud Tasks，您可以在用户或服务对服务请求之外异步执行工作。

有关该服务的更多信息，请访问 Cloud Tasks 产品文档

Google Cloud Tasks 空传感器¶

要感知队列为空，请使用 TaskQueueEmptySensor

airflow/providers/google/cloud/example_dags/example_cloud_task.py[源代码]

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