code: def testLaunch_loadInClusterSucceed(
      self,
      mock_core_api_cls,
      mock_incluster_config,
      mock_publisher,
      mock_is_inside_kfp,
      mock_kfp_namespace,
  ):
      mock_publisher.return_value.publish_execution.return_value = {}
      core_api = mock_core_api_cls.return_value
      core_api.read_namespaced_pod.side_effect = [
          self._mock_launcher_pod(),
          client.rest.ApiException(
              status=404
          ),  # Mock no existing pod state.
          self._mock_executor_pod(
              "Pending"
          ),  # Mock pending state after creation.
          self._mock_executor_pod(
              "Running"
          ),  # Mock running state after pending.
          self._mock_executor_pod("Succeeded"),  # Mock Succeeded state.
      ]
      # Mock successful pod creation.
      core_api.create_namespaced_pod.return_value = client.V1Pod()
      core_api.read_namespaced_pod_log.return_value.stream.return_value = [
          b"log-1"
      ]
      context = self._create_launcher_context()
  
      context["launcher"].launch()
  
      self.assertEqual(5, core_api.read_namespaced_pod.call_count)
      core_api.create_namespaced_pod.assert_called_once()
      core_api.read_namespaced_pod_log.assert_called_once()
      _, mock_kwargs = core_api.create_namespaced_pod.call_args
      self.assertEqual(_KFP_NAMESPACE, mock_kwargs["namespace"])
      pod_manifest = mock_kwargs["body"]
      self.assertDictEqual(
          {
              "apiVersion": "v1",
              "kind": "Pod",
              "metadata": {
                  "name": "test-123-fakecomponent-fakecomponent-123",
                  "ownerReferences": [
                      {
                          "apiVersion": "argoproj.io/v1alpha1",
                          "kind": "Workflow",
                          "name": "wf-1",
                          "uid": "wf-uid-1",
                      }
                  ],
              },
              "spec": {
                  "restartPolicy": "Never",
                  "containers": [
                      {
                          "name": "main",
                          "image": "gcr://test",
                          "command": None,
                          "args": [context["input_artifact"].uri],
                      }
                  ],
                  "serviceAccount": "sa-1",
                  "serviceAccountName": None,
              },
          },
          pod_manifest,
      )
  
imports: import os
  from unittest import mock
  from kubernetes import client
  from kubernetes import config
  import tensorflow
  from tfx.dsl.components.base import base_executor
  from tfx.dsl.components.base import executor_spec
  from tfx.orchestration import data_types
  from tfx.orchestration import metadata
  from tfx.orchestration import publisher
  from tfx.orchestration.config import kubernetes_component_config
  from tfx.orchestration.launcher import kubernetes_component_launcher
  from tfx.orchestration.launcher import test_utils
  from tfx.types import channel_utils
  from tfx.utils import kube_utils
  from ml_metadata.proto import metadata_store_pb2
label_desc: Use image node_id 2 for calling the KubernetesComponentLauncherTest obj's underlying member method code with example usage: obj.testLaunch_loadInClusterSucceed(mock_core_api_cls, mock_incluster_config, mock_publisher, mock_is_inside_kfp, mock_kfp_namespace) without return types