Fix formatting

pull/36944/head
corentin 8 months ago
parent ebc1f0eafb
commit e6a94789e1
No known key found for this signature in database
GPG Key ID: C32DB281C6350008
  1. 2
      src/python/grpcio_reflection/grpc_reflection/v1alpha/_async.py
  2. 12
      src/python/grpcio_reflection/grpc_reflection/v1alpha/_base.py
  3. 2
      src/python/grpcio_reflection/grpc_reflection/v1alpha/reflection.py
  4. 14
      src/python/grpcio_tests/tests/reflection/_reflection_servicer_test.py
  5. 18
      src/python/grpcio_tests/tests_aio/reflection/reflection_servicer_test.py

@ -57,7 +57,7 @@ class ReflectionServicer(BaseReflectionServicer):
1
].encode(),
),
original_request=request
original_request=request,
)

@ -28,7 +28,7 @@ def _not_found_error(original_request):
error_code=grpc.StatusCode.NOT_FOUND.value[0],
error_message=grpc.StatusCode.NOT_FOUND.value[1].encode(),
),
original_request=original_request
original_request=original_request,
)
@ -56,7 +56,7 @@ def _file_descriptor_response(descriptor, original_request):
file_descriptor_response=_reflection_pb2.FileDescriptorResponse(
file_descriptor_proto=(serialized_proto_list)
),
original_request=original_request
original_request=original_request,
)
@ -91,7 +91,9 @@ class BaseReflectionServicer(_reflection_pb2_grpc.ServerReflectionServicer):
else:
return _file_descriptor_response(descriptor, request)
def _file_containing_extension(self, request, containing_type, extension_number):
def _file_containing_extension(
self, request, containing_type, extension_number
):
try:
message_descriptor = self._pool.FindMessageTypeByName(
containing_type
@ -128,7 +130,7 @@ class BaseReflectionServicer(_reflection_pb2_grpc.ServerReflectionServicer):
base_type_name=message_descriptor.full_name,
extension_number=extension_numbers,
),
original_request=request
original_request=request,
)
def _list_services(self, request):
@ -139,7 +141,7 @@ class BaseReflectionServicer(_reflection_pb2_grpc.ServerReflectionServicer):
for service_name in self._service_names
]
),
original_request=request
original_request=request,
)

@ -57,7 +57,7 @@ class ReflectionServicer(BaseReflectionServicer):
1
].encode(),
),
original_request=request
original_request=request,
)

@ -121,7 +121,7 @@ class ReflectionServicerTest(unittest.TestCase):
_file_descriptor_to_proto(empty_pb2.DESCRIPTOR),
)
),
original_request=requests[0]
original_request=requests[0],
),
reflection_pb2.ServerReflectionResponse(
valid_host="",
@ -129,7 +129,7 @@ class ReflectionServicerTest(unittest.TestCase):
error_code=grpc.StatusCode.NOT_FOUND.value[0],
error_message=grpc.StatusCode.NOT_FOUND.value[1].encode(),
),
original_request=requests[1]
original_request=requests[1],
),
)
self.assertEqual(expected_responses, responses)
@ -161,7 +161,7 @@ class ReflectionServicerTest(unittest.TestCase):
_file_descriptor_to_proto(empty2_pb2.DESCRIPTOR),
)
),
original_request=requests[0]
original_request=requests[0],
),
reflection_pb2.ServerReflectionResponse(
valid_host="",
@ -169,7 +169,7 @@ class ReflectionServicerTest(unittest.TestCase):
error_code=grpc.StatusCode.NOT_FOUND.value[0],
error_message=grpc.StatusCode.NOT_FOUND.value[1].encode(),
),
original_request=requests[1]
original_request=requests[1],
),
)
self.assertEqual(expected_responses, responses)
@ -191,7 +191,7 @@ class ReflectionServicerTest(unittest.TestCase):
base_type_name=_EMPTY_EXTENSIONS_SYMBOL_NAME,
extension_number=_EMPTY_EXTENSIONS_NUMBERS,
),
original_request=requests[0]
original_request=requests[0],
),
reflection_pb2.ServerReflectionResponse(
valid_host="",
@ -199,7 +199,7 @@ class ReflectionServicerTest(unittest.TestCase):
error_code=grpc.StatusCode.NOT_FOUND.value[0],
error_message=grpc.StatusCode.NOT_FOUND.value[1].encode(),
),
original_request=requests[1]
original_request=requests[1],
),
)
self.assertEqual(expected_responses, responses)
@ -220,7 +220,7 @@ class ReflectionServicerTest(unittest.TestCase):
for name in _SERVICE_NAMES
)
),
original_request=requests[0]
original_request=requests[0],
),
)
self.assertEqual(expected_responses, responses)

@ -89,7 +89,7 @@ class ReflectionServicerTest(AioTestBase):
_file_descriptor_to_proto(empty_pb2.DESCRIPTOR),
)
),
original_request=requests[0]
original_request=requests[0],
),
reflection_pb2.ServerReflectionResponse(
valid_host="",
@ -97,7 +97,7 @@ class ReflectionServicerTest(AioTestBase):
error_code=grpc.StatusCode.NOT_FOUND.value[0],
error_message=grpc.StatusCode.NOT_FOUND.value[1].encode(),
),
original_request=requests[1]
original_request=requests[1],
),
)
self.assertSequenceEqual(expected_responses, responses)
@ -122,7 +122,7 @@ class ReflectionServicerTest(AioTestBase):
_file_descriptor_to_proto(empty_pb2.DESCRIPTOR),
)
),
original_request=requests[0]
original_request=requests[0],
),
reflection_pb2.ServerReflectionResponse(
valid_host="",
@ -130,7 +130,7 @@ class ReflectionServicerTest(AioTestBase):
error_code=grpc.StatusCode.NOT_FOUND.value[0],
error_message=grpc.StatusCode.NOT_FOUND.value[1].encode(),
),
original_request=requests[1]
original_request=requests[1],
),
)
self.assertSequenceEqual(expected_responses, responses)
@ -164,7 +164,7 @@ class ReflectionServicerTest(AioTestBase):
_file_descriptor_to_proto(empty2_pb2.DESCRIPTOR),
)
),
original_request=requests[0]
original_request=requests[0],
),
reflection_pb2.ServerReflectionResponse(
valid_host="",
@ -172,7 +172,7 @@ class ReflectionServicerTest(AioTestBase):
error_code=grpc.StatusCode.NOT_FOUND.value[0],
error_message=grpc.StatusCode.NOT_FOUND.value[1].encode(),
),
original_request=requests[1]
original_request=requests[1],
),
)
self.assertSequenceEqual(expected_responses, responses)
@ -196,7 +196,7 @@ class ReflectionServicerTest(AioTestBase):
base_type_name=_EMPTY_EXTENSIONS_SYMBOL_NAME,
extension_number=_EMPTY_EXTENSIONS_NUMBERS,
),
original_request=requests[0]
original_request=requests[0],
),
reflection_pb2.ServerReflectionResponse(
valid_host="",
@ -204,7 +204,7 @@ class ReflectionServicerTest(AioTestBase):
error_code=grpc.StatusCode.NOT_FOUND.value[0],
error_message=grpc.StatusCode.NOT_FOUND.value[1].encode(),
),
original_request=requests[1]
original_request=requests[1],
),
)
self.assertSequenceEqual(expected_responses, responses)
@ -227,7 +227,7 @@ class ReflectionServicerTest(AioTestBase):
for name in _SERVICE_NAMES
)
),
original_request=requests[0]
original_request=requests[0],
),
)
self.assertSequenceEqual(expected_responses, responses)

Loading…
Cancel
Save