tests.system.google.cloud.tasks.example_tasks

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

Functions

generate_random_string()

Generate random string for queue and task names.

Attributes

ENV_ID

DAG_ID

timestamp

LOCATION

QUEUE_ID

TASK_NAME

TASK

test_run

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]

Was this entry helpful?