Skip to content

Commit 4bb80ce

Browse files
authored
Fix gRPC warnings in API (#128)
1 parent e1b4a5e commit 4bb80ce

File tree

2 files changed

+5
-5
lines changed

2 files changed

+5
-5
lines changed

pkg/workloads/tf_api/api.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -21,10 +21,10 @@
2121
from flask import Flask, request, jsonify
2222
from flask_api import status
2323
from waitress import serve
24-
from grpc.beta import implementations
24+
import grpc
2525
from tensorflow_serving.apis import predict_pb2
2626
from tensorflow_serving.apis import get_model_metadata_pb2
27-
from tensorflow_serving.apis import prediction_service_pb2
27+
from tensorflow_serving.apis import prediction_service_pb2_grpc
2828
from lib import util, tf_lib, package, Context
2929
from lib.log import get_logger
3030
from lib.exceptions import CortexException, UserRuntimeException, UserException
@@ -323,8 +323,8 @@ def start(args):
323323
input_args_schema
324324
)
325325

326-
channel = implementations.insecure_channel("localhost", args.tf_serve_port)
327-
local_cache["stub"] = prediction_service_pb2.beta_create_PredictionService_stub(channel)
326+
channel = grpc.insecure_channel("localhost:" + str(args.tf_serve_port))
327+
local_cache["stub"] = prediction_service_pb2_grpc.PredictionServiceStub(channel)
328328

329329
local_cache["required_inputs"] = tf_lib.get_base_input_columns(model["name"], ctx)
330330

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
11
flask==1.0.2
22
flask-api==1.1
33
waitress==1.2.1
4-
tensorflow-serving-api==1.12.0
4+
tensorflow-serving-api==1.13.0

0 commit comments

Comments
 (0)