tfx.orchestration.portable.beam_dag_runner.BeamDagRunner

Tfx runner on Beam.

Inherits From: TfxRunner

Methods

run

View source

Deploys given logical pipeline on Beam.

Args
pipeline Logical pipeline in IR format.