| 
2 | 2 | import types  | 
3 | 3 | import grpc  | 
4 | 4 | from google.protobuf.json_format import ParseDict  | 
5 |  | -from google.protobuf.message_factory import MessageFactory, GetMessageClass  | 
 | 5 | +from google.protobuf.message_factory import MessageFactory #, GetMessageClass  | 
6 | 6 | from google.protobuf.descriptor_pool import DescriptorPool  | 
7 | 7 | from google.protobuf.descriptor import ServiceDescriptor, MethodDescriptor  | 
8 | 8 | from grpc_reflection.v1alpha.proto_reflection_descriptor_database import (  | 
@@ -207,14 +207,14 @@ def _bind_grpc_method(  | 
207 | 207 |  request_desc = self._desc_pool.FindMessageTypeByName(  | 
208 | 208 |  method_desc.input_type.full_name  | 
209 | 209 |  )  | 
210 |  | - # request_message_desc = MessageFactory(self._desc_pool).GetPrototype(request_desc)  | 
211 |  | - request_message_desc = GetMessageClass(request_desc)  | 
 | 210 | + request_message_desc = MessageFactory(self._desc_pool).GetPrototype(request_desc)  | 
 | 211 | + # request_message_desc = GetMessageClass(request_desc)  | 
212 | 212 | 
 
  | 
213 | 213 |  response_desc = self._desc_pool.FindMessageTypeByName(  | 
214 | 214 |  method_desc.output_type.full_name  | 
215 | 215 |  )  | 
216 |  | - # response_message_desc = MessageFactory(self._desc_pool).GetPrototype(response_desc)  | 
217 |  | - response_message_desc = GetMessageClass(response_desc)  | 
 | 216 | + response_message_desc = MessageFactory(self._desc_pool).GetPrototype(response_desc)  | 
 | 217 | + # response_message_desc = GetMessageClass(response_desc)  | 
218 | 218 | 
 
  | 
219 | 219 |  if method_desc.client_streaming and method_desc.server_streaming:  | 
220 | 220 |  setattr(  | 
@@ -286,8 +286,8 @@ def _init_grpc_reflection(self):  | 
286 | 286 |  request_desc = self._desc_pool.FindMessageTypeByName(  | 
287 | 287 |  method_desc.input_type.full_name  | 
288 | 288 |  )  | 
289 |  | - # self._request_map[method_key] = MessageFactory(self._desc_pool).GetPrototype(request_desc)  | 
290 |  | - self._request_map[method_key] = GetMessageClass(request_desc)  | 
 | 289 | + self._request_map[method_key] = MessageFactory(self._desc_pool).GetPrototype(request_desc)  | 
 | 290 | + # self._request_map[method_key] = GetMessageClass(request_desc)  | 
291 | 291 | 
 
  | 
292 | 292 |  if service_desc.name not in self._api_resources:  | 
293 | 293 |  self._api_resources[service_name] = []  | 
 | 
0 commit comments