airflow.providers.google.cloud.links.dataflow

This module contains Google Dataflow links.

Module Contents

Classes

DataflowJobLink

Helper class for constructing Dataflow Job Link.

DataflowPipelineLink

Helper class for constructing Dataflow Pipeline Link.

Attributes

DATAFLOW_BASE_LINK

DATAFLOW_JOB_LINK

DATAFLOW_PIPELINE_BASE_LINK

DATAFLOW_PIPELINE_LINK

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]

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

Helper class for constructing Dataflow Pipeline Link.

name = 'Dataflow Pipeline'[source]
key = 'dataflow_pipeline_config'[source]
format_str[source]
static persist(operator_instance, context, project_id, location, pipeline_name)[source]

Was this entry helpful?