GitHub

tfx.orchestration.beam.beam_dag_runner.BeamDagRunner

Legacy TFX BeamDagRunner.

Inherits From: TfxRunner

tfx.orchestration.beam.beam_dag_runner.BeamDagRunner()

This runner is not based on the TFX IR and is kept for compatibility. It will be deprecated in a future release.

Methods

run(
    pipeline: Union[pipeline_pb2.Pipeline, tfx.orchestration.pipeline.Pipeline]
) -> None

Deploys given logical pipeline on Beam.

Args
`pipeline`	Logical pipeline in IR format.

Except as otherwise noted, the content of this page is licensed under the Creative Commons Attribution 4.0 License, and code samples are licensed under the Apache 2.0 License. For details, see the Google Developers Site Policies. Java is a registered trademark of Oracle and/or its affiliates.

Last updated 2021-02-10 UTC.