code: def testPartialRunWithIntermediateDeploymentConfig(self):
      self._pipeline.deployment_config.Pack(
          _INTERMEDIATE_DEPLOYMENT_CONFIG
      )
      pr_opts = pipeline_pb2.PartialRun()
      pr_opts.from_nodes.append("my_trainer")
      pr_opts.to_nodes.append("my_trainer")
      pr_opts.snapshot_settings.latest_pipeline_run_strategy.SetInParent()
      beam_dag_runner.BeamDagRunner().run_with_ir(
          self._pipeline,
          run_options=pipeline_pb2.RunOptions(partial_run=pr_opts),
      )
      self.assertEqual(_executed_components, ["my_trainer"])
  
imports: import os
  from typing import Optional
  from unittest import mock
  import tensorflow
  from tfx.dsl.compiler import constants
  from tfx.orchestration import metadata
  from tfx.orchestration.beam import beam_dag_runner
  from tfx.orchestration.beam.legacy import beam_dag_runner
  from tfx.orchestration.config import pipeline_config
  from tfx.proto.orchestration import executable_spec_pb2
  from tfx.proto.orchestration import local_deployment_config_pb2
  from tfx.proto.orchestration import pipeline_pb2
  from tfx.proto.orchestration import platform_config_pb2
  from tfx.utils import test_case_utils
  from google.protobuf import message
  from google.protobuf import text_format
label_desc: Use image node_id 5 for calling the BeamDagRunnerTest obj's underlying member method code with example usage: obj.testPartialRunWithIntermediateDeploymentConfig() without return types