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

google/tests/system/google/cloud/tasks/example_queue.py[source]

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