airflow.providers.google.cloud.links.dataflow¶

This module contains Google Dataflow links.

Attributes¶

`DataflowJobLink`	Helper class for constructing Dataflow Job Link.
`DataflowPipelineLink`	Helper class for constructing Dataflow Pipeline Link.

airflow.providers.google.cloud.links.dataflow.DATAFLOW_BASE_LINK = '/dataflow/jobs'[source]¶

airflow.providers.google.cloud.links.dataflow.DATAFLOW_JOB_LINK = '/dataflow/jobs/{region}/{job_id}?project={project_id}'[source]¶

airflow.providers.google.cloud.links.dataflow.DATAFLOW_PIPELINE_BASE_LINK = '/dataflow/pipelines'[source]¶

airflow.providers.google.cloud.links.dataflow.DATAFLOW_PIPELINE_LINK = '/dataflow/pipelines/{location}/{pipeline_name}?project={project_id}'[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]¶: Name of the link. This will be the button name on the task UI.

format_str = '/dataflow/jobs/{region}/{job_id}?project={project_id}'[source]¶

static persist(operator_instance, context, project_id, region, job_id)[source]¶

class airflow.providers.google.cloud.links.dataflow.DataflowPipelineLink[source]¶

Bases: airflow.providers.google.cloud.links.base.BaseGoogleLink

Helper class for constructing Dataflow Pipeline Link.

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

format_str = '/dataflow/pipelines/{location}/{pipeline_name}?project={project_id}'[source]¶

static persist(operator_instance, context, project_id, location, pipeline_name)[source]¶