diff --git a/src/python/grpcio_tests/tests_py3_only/interop/xds_interop_client.py b/src/python/grpcio_tests/tests_py3_only/interop/xds_interop_client.py index 90501d8c4b9..f4f414e92cf 100644 --- a/src/python/grpcio_tests/tests_py3_only/interop/xds_interop_client.py +++ b/src/python/grpcio_tests/tests_py3_only/interop/xds_interop_client.py @@ -150,8 +150,8 @@ class _LoadBalancerStatsServicer(test_pb2_grpc.LoadBalancerStatsServiceServicer return response def GetClientAccumulatedStats( - self, request: messages_pb2.LoadBalancerAccumulatedStatsRequest, - context: grpc.ServicerContext + self, request: messages_pb2.LoadBalancerAccumulatedStatsRequest, + context: grpc.ServicerContext ) -> messages_pb2.LoadBalancerAccumulatedStatsResponse: logger.info("Received cumulative stats request.") response = messages_pb2.LoadBalancerAccumulatedStatsResponse() @@ -248,9 +248,9 @@ class _ChannelConfiguration: When accessing any of its members, the lock member should be held. """ - def __init__(self, method: str, metadata: Sequence[Tuple[str, str]], - qps: int, server: str, rpc_timeout_sec: int, - print_response: bool): + def __init__(self, method: str, metadata: Sequence[Tuple[str, + str]], qps: int, + server: str, rpc_timeout_sec: int, print_response: bool): # condition is signalled when a change is made to the config. self.condition = threading.Condition() @@ -306,9 +306,10 @@ class _XdsUpdateClientConfigureServicer( self._per_method_configs = per_method_configs self._qps = qps - def Configure(self, request: messages_pb2.ClientConfigureRequest, - context: grpc.ServicerContext - ) -> messages_pb2.ClientConfigureResponse: + def Configure( + self, request: messages_pb2.ClientConfigureRequest, + context: grpc.ServicerContext + ) -> messages_pb2.ClientConfigureResponse: logger.info("Received Configure RPC: %s", request) method_strs = (_METHOD_ENUM_TO_STR[t] for t in request.types) for method in _SUPPORTED_METHODS: