1
1
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
2
2
"""Client and server classes corresponding to protobuf-defined services."""
3
3
import grpc
4
+ import warnings
4
5
5
6
import api_pb2 as api__pb2
6
7
8
+ GRPC_GENERATED_VERSION = '1.65.1'
9
+ GRPC_VERSION = grpc .__version__
10
+ EXPECTED_ERROR_RELEASE = '1.66.0'
11
+ SCHEDULED_RELEASE_DATE = 'August 6, 2024'
12
+ _version_not_supported = False
13
+
14
+ try :
15
+ from grpc ._utilities import first_version_is_lower
16
+ _version_not_supported = first_version_is_lower (GRPC_VERSION , GRPC_GENERATED_VERSION )
17
+ except ImportError :
18
+ _version_not_supported = True
19
+
20
+ if _version_not_supported :
21
+ warnings .warn (
22
+ f'The grpc package installed is at version { GRPC_VERSION } ,'
23
+ + f' but the generated code in api_pb2_grpc.py depends on'
24
+ + f' grpcio>={ GRPC_GENERATED_VERSION } .'
25
+ + f' Please upgrade your grpc module to grpcio>={ GRPC_GENERATED_VERSION } '
26
+ + f' or downgrade your generated code using grpcio-tools<={ GRPC_VERSION } .'
27
+ + f' This warning will become an error in { EXPECTED_ERROR_RELEASE } ,'
28
+ + f' scheduled for release on { SCHEDULED_RELEASE_DATE } .' ,
29
+ RuntimeWarning
30
+ )
31
+
7
32
8
33
class DgraphStub (object ):
9
34
"""Graph response.
@@ -19,27 +44,27 @@ def __init__(self, channel):
19
44
'/api.Dgraph/Login' ,
20
45
request_serializer = api__pb2 .LoginRequest .SerializeToString ,
21
46
response_deserializer = api__pb2 .Response .FromString ,
22
- )
47
+ _registered_method = True )
23
48
self .Query = channel .unary_unary (
24
49
'/api.Dgraph/Query' ,
25
50
request_serializer = api__pb2 .Request .SerializeToString ,
26
51
response_deserializer = api__pb2 .Response .FromString ,
27
- )
52
+ _registered_method = True )
28
53
self .Alter = channel .unary_unary (
29
54
'/api.Dgraph/Alter' ,
30
55
request_serializer = api__pb2 .Operation .SerializeToString ,
31
56
response_deserializer = api__pb2 .Payload .FromString ,
32
- )
57
+ _registered_method = True )
33
58
self .CommitOrAbort = channel .unary_unary (
34
59
'/api.Dgraph/CommitOrAbort' ,
35
60
request_serializer = api__pb2 .TxnContext .SerializeToString ,
36
61
response_deserializer = api__pb2 .TxnContext .FromString ,
37
- )
62
+ _registered_method = True )
38
63
self .CheckVersion = channel .unary_unary (
39
64
'/api.Dgraph/CheckVersion' ,
40
65
request_serializer = api__pb2 .Check .SerializeToString ,
41
66
response_deserializer = api__pb2 .Version .FromString ,
42
- )
67
+ _registered_method = True )
43
68
44
69
45
70
class DgraphServicer (object ):
@@ -108,6 +133,7 @@ def add_DgraphServicer_to_server(servicer, server):
108
133
generic_handler = grpc .method_handlers_generic_handler (
109
134
'api.Dgraph' , rpc_method_handlers )
110
135
server .add_generic_rpc_handlers ((generic_handler ,))
136
+ server .add_registered_method_handlers ('api.Dgraph' , rpc_method_handlers )
111
137
112
138
113
139
# This class is part of an EXPERIMENTAL API.
@@ -126,11 +152,21 @@ def Login(request,
126
152
wait_for_ready = None ,
127
153
timeout = None ,
128
154
metadata = None ):
129
- return grpc .experimental .unary_unary (request , target , '/api.Dgraph/Login' ,
155
+ return grpc .experimental .unary_unary (
156
+ request ,
157
+ target ,
158
+ '/api.Dgraph/Login' ,
130
159
api__pb2 .LoginRequest .SerializeToString ,
131
160
api__pb2 .Response .FromString ,
132
- options , channel_credentials ,
133
- insecure , call_credentials , compression , wait_for_ready , timeout , metadata )
161
+ options ,
162
+ channel_credentials ,
163
+ insecure ,
164
+ call_credentials ,
165
+ compression ,
166
+ wait_for_ready ,
167
+ timeout ,
168
+ metadata ,
169
+ _registered_method = True )
134
170
135
171
@staticmethod
136
172
def Query (request ,
@@ -143,11 +179,21 @@ def Query(request,
143
179
wait_for_ready = None ,
144
180
timeout = None ,
145
181
metadata = None ):
146
- return grpc .experimental .unary_unary (request , target , '/api.Dgraph/Query' ,
182
+ return grpc .experimental .unary_unary (
183
+ request ,
184
+ target ,
185
+ '/api.Dgraph/Query' ,
147
186
api__pb2 .Request .SerializeToString ,
148
187
api__pb2 .Response .FromString ,
149
- options , channel_credentials ,
150
- insecure , call_credentials , compression , wait_for_ready , timeout , metadata )
188
+ options ,
189
+ channel_credentials ,
190
+ insecure ,
191
+ call_credentials ,
192
+ compression ,
193
+ wait_for_ready ,
194
+ timeout ,
195
+ metadata ,
196
+ _registered_method = True )
151
197
152
198
@staticmethod
153
199
def Alter (request ,
@@ -160,11 +206,21 @@ def Alter(request,
160
206
wait_for_ready = None ,
161
207
timeout = None ,
162
208
metadata = None ):
163
- return grpc .experimental .unary_unary (request , target , '/api.Dgraph/Alter' ,
209
+ return grpc .experimental .unary_unary (
210
+ request ,
211
+ target ,
212
+ '/api.Dgraph/Alter' ,
164
213
api__pb2 .Operation .SerializeToString ,
165
214
api__pb2 .Payload .FromString ,
166
- options , channel_credentials ,
167
- insecure , call_credentials , compression , wait_for_ready , timeout , metadata )
215
+ options ,
216
+ channel_credentials ,
217
+ insecure ,
218
+ call_credentials ,
219
+ compression ,
220
+ wait_for_ready ,
221
+ timeout ,
222
+ metadata ,
223
+ _registered_method = True )
168
224
169
225
@staticmethod
170
226
def CommitOrAbort (request ,
@@ -177,11 +233,21 @@ def CommitOrAbort(request,
177
233
wait_for_ready = None ,
178
234
timeout = None ,
179
235
metadata = None ):
180
- return grpc .experimental .unary_unary (request , target , '/api.Dgraph/CommitOrAbort' ,
236
+ return grpc .experimental .unary_unary (
237
+ request ,
238
+ target ,
239
+ '/api.Dgraph/CommitOrAbort' ,
181
240
api__pb2 .TxnContext .SerializeToString ,
182
241
api__pb2 .TxnContext .FromString ,
183
- options , channel_credentials ,
184
- insecure , call_credentials , compression , wait_for_ready , timeout , metadata )
242
+ options ,
243
+ channel_credentials ,
244
+ insecure ,
245
+ call_credentials ,
246
+ compression ,
247
+ wait_for_ready ,
248
+ timeout ,
249
+ metadata ,
250
+ _registered_method = True )
185
251
186
252
@staticmethod
187
253
def CheckVersion (request ,
@@ -194,8 +260,18 @@ def CheckVersion(request,
194
260
wait_for_ready = None ,
195
261
timeout = None ,
196
262
metadata = None ):
197
- return grpc .experimental .unary_unary (request , target , '/api.Dgraph/CheckVersion' ,
263
+ return grpc .experimental .unary_unary (
264
+ request ,
265
+ target ,
266
+ '/api.Dgraph/CheckVersion' ,
198
267
api__pb2 .Check .SerializeToString ,
199
268
api__pb2 .Version .FromString ,
200
- options , channel_credentials ,
201
- insecure , call_credentials , compression , wait_for_ready , timeout , metadata )
269
+ options ,
270
+ channel_credentials ,
271
+ insecure ,
272
+ call_credentials ,
273
+ compression ,
274
+ wait_for_ready ,
275
+ timeout ,
276
+ metadata ,
277
+ _registered_method = True )
0 commit comments