class_docstr: Logical TFX pipeline object.
  
  Pipeline object represents the DAG of TFX components, which can be run using
  one of the pipeline orchestration systems that TFX supports. For details,
  please refer to the
  [guide](https://github.com/tensorflow/tfx/blob/master/docs/guide/build_tfx_pipeline.md).
  
  Attributes:
    components: A deterministic list of logical components of this pipeline,
      which are deduped and topologically sorted.
    enable_cache: Whether or not cache is enabled for this run.
    metadata_connection_config: The config to connect to ML metadata.
    execution_mode: Execution mode of the pipeline. Currently only support
      synchronous execution mode.
    beam_pipeline_args: Pipeline arguments for Beam powered Components. Use
      `with_beam_pipeline_args` to set component level Beam args.
    platform_config: Pipeline level platform config, in proto form.
class_docstr_tok: ["Logical","TFX","pipeline","object",".","Pipeline","object","represents","the","DAG","of","TFX","components",",","which","can","be","run","using","one","of","the","pipeline","orchestration","systems","that","TFX","supports",".","For","details",",","please","refer","to","the","[","guide","]","(","https",":","\/\/github.com\/tensorflow\/tfx\/blob\/master\/docs\/guide\/build_tfx_pipeline.md",")",".","Attributes",":","components",":","A","deterministic","list","of","logical","components","of","this","pipeline",",","which","are","deduped","and","topologically","sorted",".","enable_cache",":","Whether","or","not","cache","is","enabled","for","this","run",".","metadata_connection_config",":","The","config","to","connect","to","ML","metadata",".","execution_mode",":","Execution","mode","of","the","pipeline",".","Currently","only","support","synchronous","execution","mode",".","beam_pipeline_args",":","Pipeline","arguments","for","Beam","powered","Components",".","Use","`","with_beam_pipeline_args","`","to","set","component","level","Beam","args",".","platform_config",":","Pipeline","level","platform","config",",","in","proto","form","."]
docstr: Beam pipeline args used for all components in the pipeline.
docstr_tok: ["Beam","pipeline","args","used","for","all","components","in","the","pipeline","."]
code: def beam_pipeline_args(self):
      """Beam pipeline args used for all components in the pipeline."""
      return self._beam_pipeline_args
  
imports: import copy
  import enum
  from typing import Any, Collection, Dict, Iterable, Iterator, List, Optional, Tuple, Union, cast
  import warnings
  from tfx.dsl.compiler import constants
  from tfx.dsl.components.base import base_node
  from tfx.dsl.components.base import executor_spec
  from tfx.dsl.context_managers import dsl_context_registry
  from tfx.dsl.experimental.conditionals import conditional
  from tfx.dsl.placeholder import placeholder
  from tfx.orchestration import data_types
  from tfx.orchestration import metadata
  from tfx.types import channel
  from tfx.types import channel_utils
  from tfx.utils import doc_controls
  from tfx.utils import topsort
  from google.protobuf import message
label_desc: Use image node_id 3 for calling the Pipeline obj's underlying member method code with example usage: obj.beam_pipeline_args() and returns: self