This module contains Google Cloud Tasks links.
Module Contents
Attributes
-
airflow.providers.google.cloud.links.cloud_tasks.CLOUD_TASKS_BASE_LINK = '/cloudtasks'[source]
-
airflow.providers.google.cloud.links.cloud_tasks.CLOUD_TASKS_QUEUE_LINK[source]
-
airflow.providers.google.cloud.links.cloud_tasks.CLOUD_TASKS_LINK[source]
-
class airflow.providers.google.cloud.links.cloud_tasks.CloudTasksQueueLink[source]
Bases: airflow.providers.google.cloud.links.base.BaseGoogleLink
Helper class for constructing Cloud Task Queue Link
-
name = 'Cloud Tasks Queue'[source]
-
key = 'cloud_task_queue'[source]
-
format_str[source]
Extract project_id, location and queue id from queue name:
projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID
-
static persist(operator_instance, context, queue_name)[source]
-
class airflow.providers.google.cloud.links.cloud_tasks.CloudTasksLink[source]
Bases: airflow.providers.google.cloud.links.base.BaseGoogleLink
Helper class for constructing Cloud Task Link
-
name = 'Cloud Tasks'[source]
-
key = 'cloud_task'[source]
-
format_str[source]
-
static persist(operator_instance, context, project_id)[source]
