Google Cloud Tasks¶

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

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

Google Cloud Tasks Empty Sensor¶

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

tests/system/google/cloud/tasks/example_queue.py

queue_sensor = TaskQueueEmptySensor(
    location=LOCATION,
    task_id="queue_sensor",
    queue_name=QUEUE_ID + "{{ task_instance.xcom_pull(task_ids='random_string') }}",
)