ac649bff69dbce9c4169cff5ec09d7b8da017f1c,testing/test_tf_serving.py,,main,#,33

Before Change

    result = None
    while True:
      try:
        result = str(stub.Predict(request, 10.0))  // 10 secs timeout
      except Exception as e:
        num_try += 1
        if num_try > 10:

After Change

  core_api = k8s_client.CoreV1Api(api_client)
  try:
    with open(args.input_path) as f:
      instances = json.loads(f.read())

    service = core_api.read_namespaced_service(args.service_name, args.namespace)
    service_ip = service.spec.cluster_ip
    model_url = "http://" + service_ip + ":8000/model/mnist:predict"

    num_try = 1
    result = None
    while True:
      try:
        result = requests.post(model_url, json=instances)
        assert(result.status_code == 200)
      except Exception as e:
        num_try += 1
        if num_try > 10:

Instances