Example Airflow DAG that creates, gets, lists, updates, purges, pauses, resumes
and deletes Queues in the Google Cloud Tasks service in the Google Cloud.
Module Contents
Attributes
-
tests.system.providers.google.cloud.tasks.example_queue.ENV_ID[source]
-
tests.system.providers.google.cloud.tasks.example_queue.DAG_ID = cloud_tasks_queue[source]
-
tests.system.providers.google.cloud.tasks.example_queue.LOCATION = europe-central2[source]
-
tests.system.providers.google.cloud.tasks.example_queue.QUEUE_ID[source]
-
tests.system.providers.google.cloud.tasks.example_queue.generate_random_string()[source]
Generate random string for queue and task names.
Queue name cannot be repeated in preceding 7 days and
task name in the last 1 hour.
-
tests.system.providers.google.cloud.tasks.example_queue.test_run[source]