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


Tfx runner on Beam.

Inherits From: TfxRunner

beam_orchestrator_args beam args for the beam orchestrator. Note that this is different from the beam_pipeline_args within additional_pipeline_args, which is for beam pipelines in components.
config Optional pipeline config for customizing the launching of each component. Defaults to pipeline config that supports InProcessComponentLauncher and DockerComponentLauncher.



View source

Deploys given logical pipeline on Beam.

tfx_pipeline Logical pipeline containing pipeline args and components.