code: def testPipelineWithBeamPipelineArgs(self):
      expected_args = [
          "--my_first_beam_pipeline_args=foo",
          "--my_second_beam_pipeline_args=bar",
      ]
      p = pipeline.Pipeline(
          pipeline_name="a",
          pipeline_root="b",
          log_root="c",
          components=[
              _make_fake_component_instance(
                  "component_a", _OutputTypeA, {}, {}, with_beam=True
              ).with_beam_pipeline_args([expected_args[1]])
          ],
          beam_pipeline_args=[expected_args[0]],
          metadata_connection_config=self._metadata_connection_config,
      )
      self.assertEqual(
          expected_args,
          p.components[0].executor_spec.beam_pipeline_args,
      )
  
imports: import itertools
  import os
  from typing import Any, Dict, Optional, Type
  import tensorflow
  from tfx import types
  from tfx.dsl.components.base import base_beam_component
  from tfx.dsl.components.base import base_component
  from tfx.dsl.components.base import base_executor
  from tfx.dsl.components.base import base_node
  from tfx.dsl.components.base import executor_spec
  from tfx.dsl.placeholder import placeholder
  from tfx.orchestration import metadata
  from tfx.orchestration import pipeline
  from tfx.types.component_spec import ChannelParameter
  from tfx.types.component_spec import ExecutionParameter
  from tfx.utils import test_case_utils
label_desc: Use image node_id 10 for calling the PipelineTest obj's underlying member method code with example usage: obj.testPipelineWithBeamPipelineArgs() without return types