class_docstr: Instance of SubmittedRun corresponding to a Kubernetes Job run launched to run an MLflow
  project.
  :param mlflow_run_id: ID of the MLflow project run.
  :param job_name: Kubernetes job name.
  :param job_namespace: Kubernetes job namespace.
class_docstr_tok: ["Instance","of","SubmittedRun","corresponding","to","a","Kubernetes","Job","run","launched","to","run","an","MLflow","project",".",":","param","mlflow_run_id",":","ID","of","the","MLflow","project","run",".",":","param","job_name",":","Kubernetes","job","name",".",":","param","job_namespace",":","Kubernetes","job","namespace","."]
code: def _update_status(self):
      api_response = self._kube_api.read_namespaced_job_status(
          name=self._job_name,
          namespace=self._job_namespace,
          pretty=True,
      )
      status = api_response.status
      with self._status_lock:
          if RunStatus.is_terminated(self._status):
              return self._status
          if self._status == RunStatus.SCHEDULED:
              if api_response.status.start_time is None:
                  _logger.info("Waiting for Job to start")
              else:
                  _logger.info("Job started.")
                  self._status = RunStatus.RUNNING
          if status.conditions is not None:
              for condition in status.conditions:
                  if condition.status == "True":
                      _logger.info(condition.message)
                      if condition.type == "Failed":
                          self._status = RunStatus.FAILED
                      elif condition.type == "Complete":
                          self._status = RunStatus.FINISHED
      return self._status
  
imports: import logging
  import os
  import time
  from datetime import datetime
  from shlex import quote, split
  from threading import RLock
  import kubernetes
  from kubernetes.config.config_exception import ConfigException
  import docker
  from mlflow.entities import RunStatus
  from mlflow.exceptions import ExecutionException
  from mlflow.projects.submitted_run import SubmittedRun
label_desc: Use image node_id 4 for calling the KubernetesSubmittedRun obj's underlying member method code with example usage: obj._update_status() and returns: self, self