5
5
from model .ray .v1alpha import user_defined_pb2 as model_dot_ray_dot_v1alpha_dot_user__defined__pb2
6
6
7
7
8
- class RayUserDefinedServiceStub (object ):
9
- """Ray user defined service for internal process
8
+ class UserDefinedServiceStub (object ):
9
+ """User defined service for internal process
10
10
"""
11
11
12
12
def __init__ (self , channel ):
@@ -16,14 +16,14 @@ def __init__(self, channel):
16
16
channel: A grpc.Channel.
17
17
"""
18
18
self .__call__ = channel .unary_unary (
19
- '/model.ray.v1alpha.RayUserDefinedService /__call__' ,
19
+ '/model.ray.v1alpha.UserDefinedService /__call__' ,
20
20
request_serializer = model_dot_ray_dot_v1alpha_dot_user__defined__pb2 .CallRequest .SerializeToString ,
21
21
response_deserializer = model_dot_ray_dot_v1alpha_dot_user__defined__pb2 .CallResponse .FromString ,
22
22
)
23
23
24
24
25
- class RayUserDefinedServiceServicer (object ):
26
- """Ray user defined service for internal process
25
+ class UserDefinedServiceServicer (object ):
26
+ """User defined service for internal process
27
27
"""
28
28
29
29
def __call__ (self , request , context ):
@@ -36,7 +36,7 @@ def __call__(self, request, context):
36
36
raise NotImplementedError ('Method not implemented!' )
37
37
38
38
39
- def add_RayUserDefinedServiceServicer_to_server (servicer , server ):
39
+ def add_UserDefinedServiceServicer_to_server (servicer , server ):
40
40
rpc_method_handlers = {
41
41
'__call__' : grpc .unary_unary_rpc_method_handler (
42
42
servicer .__call__ ,
@@ -45,13 +45,13 @@ def add_RayUserDefinedServiceServicer_to_server(servicer, server):
45
45
),
46
46
}
47
47
generic_handler = grpc .method_handlers_generic_handler (
48
- 'model.ray.v1alpha.RayUserDefinedService ' , rpc_method_handlers )
48
+ 'model.ray.v1alpha.UserDefinedService ' , rpc_method_handlers )
49
49
server .add_generic_rpc_handlers ((generic_handler ,))
50
50
51
51
52
52
# This class is part of an EXPERIMENTAL API.
53
- class RayUserDefinedService (object ):
54
- """Ray user defined service for internal process
53
+ class UserDefinedService (object ):
54
+ """User defined service for internal process
55
55
"""
56
56
57
57
@staticmethod
@@ -65,7 +65,7 @@ def __call__(request,
65
65
wait_for_ready = None ,
66
66
timeout = None ,
67
67
metadata = None ):
68
- return grpc .experimental .unary_unary (request , target , '/model.ray.v1alpha.RayUserDefinedService /__call__' ,
68
+ return grpc .experimental .unary_unary (request , target , '/model.ray.v1alpha.UserDefinedService /__call__' ,
69
69
model_dot_ray_dot_v1alpha_dot_user__defined__pb2 .CallRequest .SerializeToString ,
70
70
model_dot_ray_dot_v1alpha_dot_user__defined__pb2 .CallResponse .FromString ,
71
71
options , channel_credentials ,
0 commit comments