This module contains Google Dataflow links.
Module Contents
Attributes
-
airflow.providers.google.cloud.links.dataflow.DATAFLOW_BASE_LINK = '/dataflow/jobs'[source]
-
airflow.providers.google.cloud.links.dataflow.DATAFLOW_JOB_LINK[source]
-
class airflow.providers.google.cloud.links.dataflow.DataflowJobLink[source]
Bases: airflow.providers.google.cloud.links.base.BaseGoogleLink
Helper class for constructing Dataflow Job Link.
-
name = 'Dataflow Job'[source]
-
key = 'dataflow_job_config'[source]
-
format_str[source]
-
static persist(operator_instance, context, project_id, region, job_id)[source]