airflow.providers.google.cloud.links.datafusion

This module contains Google Data Fusion links.

Module Contents

Classes

BaseGoogleLink

Link for Google operators.

DataFusionInstanceLink

Helper class for constructing Data Fusion Instance link.

DataFusionPipelineLink

Helper class for constructing Data Fusion Pipeline link.

DataFusionPipelinesLink

Helper class for constructing list of Data Fusion Pipelines link.

Attributes

BASE_LINK

DATAFUSION_INSTANCE_LINK

DATAFUSION_PIPELINES_LINK

DATAFUSION_PIPELINE_LINK

Bases: airflow.models.BaseOperatorLink

Link for Google operators.

Prevent adding https://console.cloud.google.com in front of every link where URI is used.

name: ClassVar[str][source]
key: ClassVar[str][source]
format_str: ClassVar[str][source]

Link to external system.

Note: The old signature of this function was (self, operator, dttm: datetime). That is still supported at runtime but is deprecated.

Parameters
Returns

link to external system

Return type

str

Bases: BaseGoogleLink

Helper class for constructing Data Fusion Instance link.

name = 'Data Fusion Instance'[source]
key = 'instance_conf'[source]
format_str[source]
static persist(context, task_instance, location, instance_name, project_id)[source]

Bases: BaseGoogleLink

Helper class for constructing Data Fusion Pipeline link.

name = 'Data Fusion Pipeline'[source]
key = 'pipeline_conf'[source]
format_str[source]
static persist(context, task_instance, uri, pipeline_name, namespace)[source]

Bases: BaseGoogleLink

Helper class for constructing list of Data Fusion Pipelines link.

name = 'Data Fusion Pipelines List'[source]
key = 'pipelines_conf'[source]
format_str[source]
static persist(context, task_instance, uri, namespace)[source]

Was this entry helpful?