airflow.providers.google.cloud.links.cloud_tasks

This module contains Google Cloud Tasks links.

Module Contents

Classes

CloudTasksQueueLink

Helper class for constructing Cloud Task Queue Link

CloudTasksLink

Helper class for constructing Cloud Task Link

Attributes

CLOUD_TASKS_BASE_LINK

CLOUD_TASKS_QUEUE_LINK

CLOUD_TASKS_LINK

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]
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]

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]

Was this entry helpful?