airflow.providers.google.cloud.links.cloud_tasks¶

This module contains Google Cloud Tasks links.

Attributes¶

`CloudTasksQueueLink`	Helper class for constructing Cloud Task Queue Link.
`CloudTasksLink`	Helper class for constructing Cloud Task Link.

airflow.providers.google.cloud.links.cloud_tasks.CLOUD_TASKS_BASE_LINK = '/cloudtasks'[source]¶

airflow.providers.google.cloud.links.cloud_tasks.CLOUD_TASKS_QUEUE_LINK = '/cloudtasks/queue/{location}/{queue_id}/tasks?project={project_id}'[source]¶

airflow.providers.google.cloud.links.cloud_tasks.CLOUD_TASKS_LINK = '/cloudtasks?project={project_id}'[source]¶

class airflow.providers.google.cloud.links.cloud_tasks.CloudTasksQueueLink[source]¶

Helper class for constructing Cloud Task Queue Link.

name = 'Cloud Tasks Queue'[source]¶: Name of the link. This will be the button name on the task UI.

format_str = '/cloudtasks/queue/{location}/{queue_id}/tasks?project={project_id}'[source]¶

static extract_parts(queue_name)[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]¶

Helper class for constructing Cloud Task Link.

name = 'Cloud Tasks'[source]¶: Name of the link. This will be the button name on the task UI.

static persist(operator_instance, context, project_id)[source]¶