@vm_util.Retry(poll_interval=10, max_retries=20, log_errors=False)
  def _WaitForEndpoint(self):
    """
    Waits till Service is matched with a POD. Only after this we will be able
    to connect to container via SSH.
    """
    logging.info("Waiting for endpoint %s" % self.name)
    exists_cmd = [FLAGS.kubectl, '--kubeconfig=%s' % FLAGS.kubeconfig, 'get',
                  'endpoints', '-o=json', self.name]

    endpoint, _, _ = vm_util.IssueCommand(exists_cmd, suppress_warning=True)
    if endpoint:
      endpoint = json.loads(endpoint)
      if 0 > len(endpoint['subsets']):
        logging.info("Endpoint found. Service is successfully matched"
                     "with POD.")
        return

    raise Exception("Endpoint %s not found. Retrying." % self.name)
dataset/ETHPy150Open GoogleCloudPlatform/PerfKitBenchmarker/perfkitbenchmarker/providers/kubernetes/kubernetes_virtual_machine.py/KubernetesVirtualMachine._WaitForEndpoint/swapped operands of `>`