tfx.orchestration.airflow.airflow_dag_runner.AirflowDagRunner

Tfx runner on Airflow.

Inherits From: TfxRunner

tfx.orchestration.airflow.airflow_dag_runner.AirflowDagRunner(
    config: Optional[Union[Dict[Text, Any], tfx.orchestration.airflow.airflow_dag_runner.AirflowPipelineConfig]] = None
)

Args
config	Optional Airflow pipeline config for customizing the launching of each component.

Methods

run

View source

run(
    tfx_pipeline: tfx.orchestration.pipeline.Pipeline
)

Deploys given logical pipeline on Airflow.

Args
tfx_pipeline	Logical pipeline containing pipeline args and components.

Returns
An Airflow DAG.