def _construct_pipeline():
    'Constructs a Kubeflow pipeline.\n\n      Creates Kubeflow ContainerOps for each TFX component encountered in the\n      logical pipeline definition.\n      '
    self._construct_pipeline_graph(pipeline, dsl_pipeline_root)
Constructs a Kubeflow pipeline.

Creates Kubeflow ContainerOps for each TFX component encountered in the
logical pipeline definition.
def _construct_pipeline():
    'Constructs a Kubeflow pipeline.\n\n      Creates Kubeflow ContainerOps for each TFX component encountered in the\n      logical pipeline definition.\n      '
    self._construct_pipeline_graph(pipeline, dsl_pipeline_root)