airflow.providers.google.cloud.links.datafusion
¶
This module contains Google Data Fusion links.
Module Contents¶
Classes¶
Link for Google operators. |
|
Helper class for constructing Data Fusion Instance link. |
|
Helper class for constructing Data Fusion Pipeline link. |
|
Helper class for constructing list of Data Fusion Pipelines link. |
Attributes¶
- airflow.providers.google.cloud.links.datafusion.BASE_LINK = 'https://console.cloud.google.com/data-fusion'[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.- 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
- class airflow.providers.google.cloud.links.datafusion.DataFusionInstanceLink[source]¶
Bases:
BaseGoogleLink
Helper class for constructing Data Fusion Instance link.
- class airflow.providers.google.cloud.links.datafusion.DataFusionPipelineLink[source]¶
Bases:
BaseGoogleLink
Helper class for constructing Data Fusion Pipeline link.
- class airflow.providers.google.cloud.links.datafusion.DataFusionPipelinesLink[source]¶
Bases:
BaseGoogleLink
Helper class for constructing list of Data Fusion Pipelines link.