code: def __verify_job_has_started(self):
          
          # Verify that the job started
          self.__get_job()
  
          # Verify that the pod started
          pods = self.__get_pods()
  
          assert len(pods) > 0, "No pod scheduled by " + self.uu_name
          for pod in pods:
              status = pod.obj['status']
              for cont_stats in status.get('containerStatuses', []):
                  if 'terminated' in cont_stats['state']:
                      t = cont_stats['state']['terminated']
                      err_msg = "Pod %s %s (exit code %d). Logs: `kubectl logs pod/%s`" % (
                          pod.name, t['reason'], t['exitCode'], pod.name)
                      assert t['exitCode'] == 0, err_msg
  
                  if 'waiting' in cont_stats['state']:
                      wr = cont_stats['state']['waiting']['reason']
                      assert wr == 'ContainerCreating', "Pod %s %s. Logs: `kubectl logs pod/%s`" % (
                          pod.name, wr, pod.name)
  
              for cond in status.get('conditions', []):
                  if 'message' in cond:
                      if cond['reason'] == 'ContainersNotReady':
                          return False
                      assert cond['status'] != 'False', \
                          "[ERROR] %s - %s" % (cond['reason'], cond['message'])
          return True
docs: Asserts that the job has successfully started