airflow.providers.google.cloud.links.datafusion¶

This module contains Google Data Fusion links.

Attributes¶

`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.

airflow.providers.google.cloud.links.datafusion.BASE_LINK = 'https://console.cloud.google.com/data-fusion'[source]¶

airflow.providers.google.cloud.links.datafusion.DATAFUSION_INSTANCE_LINK = 'https://console.cloud.google.com/data-fusion/locations/{region}/instances/{instance_name}?projec...[source]¶

airflow.providers.google.cloud.links.datafusion.DATAFUSION_PIPELINES_LINK = '{uri}/cdap/ns/{namespace}/pipelines'[source]¶

airflow.providers.google.cloud.links.datafusion.DATAFUSION_PIPELINE_LINK = '{uri}/pipelines/ns/{namespace}/view/{pipeline_name}'[source]¶

class airflow.providers.google.cloud.links.datafusion.BaseGoogleLink[source]¶

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]¶: Name of the link. This will be the button name on the task UI.

get_link(operator, *, ti_key)[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:

operator (airflow.models.BaseOperator) – The Airflow operator object this link is associated to.
ti_key (airflow.models.taskinstancekey.TaskInstanceKey) – TaskInstance ID to return link for.

Returns:

link to external system

Return type:

str

class airflow.providers.google.cloud.links.datafusion.DataFusionInstanceLink[source]¶

Helper class for constructing Data Fusion Instance link.

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

format_str = 'https://console.cloud.google.com/data-fusion/locations/{region}/instances/{instance_name}?projec...[source]¶

static persist(context, task_instance, location, instance_name, project_id)[source]¶

class airflow.providers.google.cloud.links.datafusion.DataFusionPipelineLink[source]¶

Helper class for constructing Data Fusion Pipeline link.

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

static persist(context, task_instance, uri, pipeline_name, namespace)[source]¶

class airflow.providers.google.cloud.links.datafusion.DataFusionPipelinesLink[source]¶

Helper class for constructing list of Data Fusion Pipelines link.

name = 'Data Fusion Pipelines List'[source]¶: Name of the link. This will be the button name on the task UI.

static persist(context, task_instance, uri, namespace)[source]¶