| :py:mod:`tests.system.providers.google.cloud.tasks.example_tasks` |
| ================================================================= |
| |
| .. py:module:: tests.system.providers.google.cloud.tasks.example_tasks |
| |
| .. autoapi-nested-parse:: |
| |
| 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 |
| ~~~~~~~~~ |
| |
| .. autoapisummary:: |
| |
| tests.system.providers.google.cloud.tasks.example_tasks.generate_random_string |
| |
| |
| |
| Attributes |
| ~~~~~~~~~~ |
| |
| .. autoapisummary:: |
| |
| tests.system.providers.google.cloud.tasks.example_tasks.ENV_ID |
| tests.system.providers.google.cloud.tasks.example_tasks.DAG_ID |
| tests.system.providers.google.cloud.tasks.example_tasks.timestamp |
| tests.system.providers.google.cloud.tasks.example_tasks.LOCATION |
| tests.system.providers.google.cloud.tasks.example_tasks.QUEUE_ID |
| tests.system.providers.google.cloud.tasks.example_tasks.TASK_NAME |
| tests.system.providers.google.cloud.tasks.example_tasks.TASK |
| tests.system.providers.google.cloud.tasks.example_tasks.test_run |
| |
| |
| .. py:data:: ENV_ID |
| |
| |
| |
| |
| .. py:data:: DAG_ID |
| :annotation: = cloud_tasks_tasks |
| |
| |
| |
| .. py:data:: timestamp |
| |
| |
| |
| |
| .. py:data:: LOCATION |
| :annotation: = europe-central2 |
| |
| |
| |
| .. py:data:: QUEUE_ID |
| |
| |
| |
| |
| .. py:data:: TASK_NAME |
| :annotation: = task-to-run |
| |
| |
| |
| .. py:data:: TASK |
| |
| |
| |
| |
| .. py:function:: generate_random_string() |
| |
| 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. |
| |
| |
| .. py:data:: test_run |
| |
| |
| |
| |