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

This module contains Google Compute Engine links.

Module Contents¶

`BaseGoogleLink`	Override the base logic to prevent adding 'https://console.cloud.google.com'
`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[source]¶

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

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

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

Bases: airflow.models.BaseOperatorLink

Override the base logic to prevent adding ‘https://console.cloud.google.com’ in front of every link where uri is used

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