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.google.cloud.tasks.example_tasks.ENV_ID[source]
-
tests.system.google.cloud.tasks.example_tasks.DAG_ID = 'cloud_tasks_tasks'[source]
-
tests.system.google.cloud.tasks.example_tasks.timestamp[source]
-
tests.system.google.cloud.tasks.example_tasks.LOCATION = 'us-central1'[source]
-
tests.system.google.cloud.tasks.example_tasks.QUEUE_ID[source]
-
tests.system.google.cloud.tasks.example_tasks.TASK_NAME = 'task-to-run'[source]
-
tests.system.google.cloud.tasks.example_tasks.TASK[source]
-
tests.system.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.google.cloud.tasks.example_tasks.test_run[source]