def _construct_pipeline_graph(self, pipeline: tfx_pipeline.Pipeline, pipeline_root: dsl.PipelineParam):
    'Constructs a Kubeflow Pipeline graph.\n\n    Args:\n      pipeline: The logical TFX pipeline to base the construction on.\n      pipeline_root: dsl.PipelineParam representing the pipeline root.\n    '
    component_to_kfp_op = {}
    tfx_ir = self._generate_tfx_ir(pipeline)
    for component in pipeline.components:
        depends_on = set()
        for upstream_component in component.upstream_nodes:
            depends_on.add(component_to_kfp_op[upstream_component])
        kfp_component = base_component.BaseComponent(component=component, depends_on=depends_on, pipeline=pipeline, pipeline_root=pipeline_root, tfx_image=self._config.tfx_image, kubeflow_metadata_config=self._config.kubeflow_metadata_config, pod_labels_to_attach=self._pod_labels_to_attach, tfx_ir=tfx_ir)
        for operator in self._config.pipeline_operator_funcs:
            kfp_component.container_op.apply(operator)
        component_to_kfp_op[component] = kfp_component.container_op
Constructs a Kubeflow Pipeline graph.

Args:
  pipeline: The logical TFX pipeline to base the construction on.
  pipeline_root: dsl.PipelineParam representing the pipeline root.
def _construct_pipeline_graph(self, pipeline: tfx_pipeline.Pipeline, pipeline_root: dsl.PipelineParam):
    'Constructs a Kubeflow Pipeline graph.\n\n    Args:\n      pipeline: The logical TFX pipeline to base the construction on.\n      pipeline_root: dsl.PipelineParam representing the pipeline root.\n    '
    component_to_kfp_op = {}
    tfx_ir = self._generate_tfx_ir(pipeline)
    for component in pipeline.components:
        depends_on = set()
        for upstream_component in component.upstream_nodes:
            depends_on.add(component_to_kfp_op[upstream_component])
        kfp_component = base_component.BaseComponent(component=component, depends_on=depends_on, pipeline=pipeline, pipeline_root=pipeline_root, tfx_image=self._config.tfx_image, kubeflow_metadata_config=self._config.kubeflow_metadata_config, pod_labels_to_attach=self._pod_labels_to_attach, tfx_ir=tfx_ir)
        for operator in self._config.pipeline_operator_funcs:
            kfp_component.container_op.apply(operator)
        component_to_kfp_op[component] = kfp_component.container_op