def run(self, pipeline: tfx_pipeline.Pipeline):
    'Compiles and outputs a Kubeflow Pipeline YAML definition file.\n\n    Args:\n      pipeline: The logical TFX pipeline to use when building the Kubeflow\n        pipeline.\n    '
    for component in pipeline.components:
        if isinstance(component, tfx_base_component.BaseComponent):
            component._resolve_pip_dependencies(pipeline.pipeline_info.pipeline_root)
    dsl_pipeline_root = dsl.PipelineParam(name=tfx_pipeline.ROOT_PARAMETER.name, value=pipeline.pipeline_info.pipeline_root)
    self._params.append(dsl_pipeline_root)

    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)
    self._parse_parameter_from_pipeline(pipeline)
    file_name = (self._output_filename or get_default_output_filename(pipeline.pipeline_info.pipeline_name))
    self._compiler._create_and_write_workflow(pipeline_func=_construct_pipeline, pipeline_name=pipeline.pipeline_info.pipeline_name, params_list=self._params, package_path=os.path.join(self._output_dir, file_name))
Compiles and outputs a Kubeflow Pipeline YAML definition file.

Args:
  pipeline: The logical TFX pipeline to use when building the Kubeflow
    pipeline.
def run(self, pipeline: tfx_pipeline.Pipeline):
    'Compiles and outputs a Kubeflow Pipeline YAML definition file.\n\n    Args:\n      pipeline: The logical TFX pipeline to use when building the Kubeflow\n        pipeline.\n    '
    for component in pipeline.components:
        if isinstance(component, tfx_base_component.BaseComponent):
            component._resolve_pip_dependencies(pipeline.pipeline_info.pipeline_root)
    dsl_pipeline_root = dsl.PipelineParam(name=tfx_pipeline.ROOT_PARAMETER.name, value=pipeline.pipeline_info.pipeline_root)
    self._params.append(dsl_pipeline_root)

    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)
    self._parse_parameter_from_pipeline(pipeline)
    file_name = (self._output_filename or get_default_output_filename(pipeline.pipeline_info.pipeline_name))
    self._compiler._create_and_write_workflow(pipeline_func=_construct_pipeline, pipeline_name=pipeline.pipeline_info.pipeline_name, params_list=self._params, package_path=os.path.join(self._output_dir, file_name))