Example Airflow DAG that creates and deletes Queues and creates, gets, lists,
runs and deletes Tasks in the Google Cloud Tasks service in the Google Cloud.
Module Contents
Attributes
-
tests.system.providers.google.cloud.tasks.example_tasks.ENV_ID[source]
-
tests.system.providers.google.cloud.tasks.example_tasks.DAG_ID = cloud_tasks_tasks[source]
-
tests.system.providers.google.cloud.tasks.example_tasks.timestamp[source]
-
tests.system.providers.google.cloud.tasks.example_tasks.LOCATION = europe-central2[source]
-
tests.system.providers.google.cloud.tasks.example_tasks.QUEUE_ID[source]
-
tests.system.providers.google.cloud.tasks.example_tasks.TASK_NAME = task-to-run[source]
-
tests.system.providers.google.cloud.tasks.example_tasks.TASK[source]
-
tests.system.providers.google.cloud.tasks.example_tasks.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_tasks.test_run[source]