Skip to content

Commit

Permalink
Merge pull request #520 from mustyoshi/patch-2
Browse files Browse the repository at this point in the history
seldpon_grpc_endpoint -> seldon_grpc_endpoint
  • Loading branch information
ukclivecox committed Apr 19, 2019
2 parents 28763bb + 77e924b commit a587d6f
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions python/seldon_core/seldon_client.py
Original file line number Diff line number Diff line change
Expand Up @@ -928,7 +928,7 @@ def rest_predict_seldon_oauth(oauth_key: str, oauth_secret: str, namespace: str

def grpc_predict_seldon_oauth(oauth_key: str, oauth_secret: str, namespace: str = None,
seldon_rest_endpoint: str = "localhost:8002",
seldpon_grpc_endpoint: str = "localhost:8004", shape: Tuple[int, int] = (1, 1),
seldon_grpc_endpoint: str = "localhost:8004", shape: Tuple[int, int] = (1, 1),
data: np.ndarray = None, payload_type: str = "tensor",
bin_data: Union[bytes, bytearray] = None, str_data: str = None,
grpc_max_send_message_length: int = 4 * 1024 * 1024,
Expand Down Expand Up @@ -981,7 +981,7 @@ def grpc_predict_seldon_oauth(oauth_key: str, oauth_secret: str, namespace: str
data = np.random.rand(*shape)
datadef = array_to_grpc_datadef(payload_type, data, names=names)
request = prediction_pb2.SeldonMessage(data=datadef)
channel = grpc.insecure_channel(seldpon_grpc_endpoint, options=[
channel = grpc.insecure_channel(seldon_grpc_endpoint, options=[
('grpc.max_send_message_length', grpc_max_send_message_length),
('grpc.max_receive_message_length', grpc_max_receive_message_length)])
stub = prediction_pb2_grpc.SeldonStub(channel)
Expand Down Expand Up @@ -1287,7 +1287,7 @@ def grpc_feedback_seldon_oauth(prediction_request: prediction_pb2.SeldonMessage
prediction_response: prediction_pb2.SeldonMessage = None, reward: float = 0,
oauth_key: str = "", oauth_secret: str = "", namespace: str = None,
seldon_rest_endpoint: str = "localhost:8002",
seldpon_grpc_endpoint: str = "localhost:8004",
seldon_grpc_endpoint: str = "localhost:8004",
grpc_max_send_message_length: int = 4 * 1024 * 1024,
grpc_max_receive_message_length: int = 4 * 1024 * 1024,
**kwargs) -> SeldonClientFeedback:
Expand All @@ -1310,7 +1310,7 @@ def grpc_feedback_seldon_oauth(prediction_request: prediction_pb2.SeldonMessage
k8s namespace of running deployment
seldon_rest_endpoint
Endpoint of REST endpoint
seldpon_grpc_endpoint
seldon_grpc_endpoint
Endpoint for Seldon grpc
grpc_max_send_message_length
Max grpc send message size in bytes
Expand All @@ -1324,7 +1324,7 @@ def grpc_feedback_seldon_oauth(prediction_request: prediction_pb2.SeldonMessage
"""
token = get_token(oauth_key, oauth_secret, namespace, seldon_rest_endpoint)
request = prediction_pb2.Feedback(request=prediction_request, response=prediction_response, reward=reward)
channel = grpc.insecure_channel(seldpon_grpc_endpoint, options=[
channel = grpc.insecure_channel(seldon_grpc_endpoint, options=[
('grpc.max_send_message_length', grpc_max_send_message_length),
('grpc.max_receive_message_length', grpc_max_receive_message_length)])
stub = prediction_pb2_grpc.SeldonStub(channel)
Expand Down

0 comments on commit a587d6f

Please sign in to comment.