code: def testWaitUntilRunning_FailsIfJobAborted(self, mock_time):
      # Prepare mocks and variables.
      self._AssumeInsideKfp()
      runner = self._CreateKubernetesRunner()
      mock_time.side_effect = list(range(20))
      terminated_pod = mock.Mock()
      terminated_pod.status.phase = "Succeeded"
      self._mock_core_v1_api.read_namespaced_pod.return_value = (
          terminated_pod
      )
  
      # Act.
      runner.Start()
      with self.assertRaises(error_types.JobAborted):
          runner.WaitUntilRunning(deadline=10)
  
imports: import os
  from typing import Any, Dict
  from unittest import mock
  from kubernetes import client
  from kubernetes.client import rest
  import tensorflow
  from tfx.components.infra_validator import error_types
  from tfx.components.infra_validator import serving_bins
  from tfx.components.infra_validator.model_server_runners import kubernetes_runner
  from tfx.proto import infra_validator_pb2
  from tfx.types import standard_artifacts
  from tfx.utils import kube_utils
  from tfx.utils import path_utils
  from google.protobuf import json_format
label_desc: Use image node_id 13 for calling the KubernetesRunnerTest obj's underlying member method code with example usage: obj.testWaitUntilRunning_FailsIfJobAborted(mock_time) without return types