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?