Join the SIG TFX-Addons community and help make TFX even better!

tfx.orchestration.local.legacy.local_dag_runner.LocalDagRunner

Local TFX DAG runner.

Inherits From: TfxRunner

tfx.orchestration.local.legacy.local_dag_runner.LocalDagRunner(
    config: Optional[tfx.orchestration.config.pipeline_config.PipelineConfig] = None
)

config Optional pipeline config for customizing the launching of each component. Defaults to pipeline config that supports InProcessComponentLauncher and DockerComponentLauncher.

Methods

run

View source

run(
    tfx_pipeline: tfx.orchestration.pipeline.Pipeline
) -> None

Runs given logical pipeline locally.

Args
tfx_pipeline Logical pipeline containing pipeline args and components.