1 files changed, 112 insertions, 111 deletions
diff --git a/src/python/grpcio_tests/tests/unit/_invalid_metadata_test.py b/src/python/grpcio_tests/tests/unit/_invalid_metadata_test.py
index 2dc225de29..1b1b1bd598 100644
--- a/src/python/grpcio_tests/tests/unit/_invalid_metadata_test.py
+++ b/src/python/grpcio_tests/tests/unit/_invalid_metadata_test.py
@@ -26,7 +26,6 @@
 # THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 # (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
 # OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
-
 """Test of RPCs made against gRPC Python's application-layer API."""
 
 import unittest
@@ -47,129 +46,131 @@ _STREAM_STREAM = '/test/StreamStream'
 
 
 def _unary_unary_multi_callable(channel):
-  return channel.unary_unary(_UNARY_UNARY)
+    return channel.unary_unary(_UNARY_UNARY)
 
 
 def _unary_stream_multi_callable(channel):
-  return channel.unary_stream(
-      _UNARY_STREAM,
-      request_serializer=_SERIALIZE_REQUEST,
-      response_deserializer=_DESERIALIZE_RESPONSE)
+    return channel.unary_stream(
+        _UNARY_STREAM,
+        request_serializer=_SERIALIZE_REQUEST,
+        response_deserializer=_DESERIALIZE_RESPONSE)
 
 
 def _stream_unary_multi_callable(channel):
-  return channel.stream_unary(
-      _STREAM_UNARY,
-      request_serializer=_SERIALIZE_REQUEST,
-      response_deserializer=_DESERIALIZE_RESPONSE)
+    return channel.stream_unary(
+        _STREAM_UNARY,
+        request_serializer=_SERIALIZE_REQUEST,
+        response_deserializer=_DESERIALIZE_RESPONSE)
 
 
 def _stream_stream_multi_callable(channel):
-  return channel.stream_stream(_STREAM_STREAM)
+    return channel.stream_stream(_STREAM_STREAM)
 
 
 class InvalidMetadataTest(unittest.TestCase):
 
-  def setUp(self):
-    self._channel = grpc.insecure_channel('localhost:8080')
-    self._unary_unary = _unary_unary_multi_callable(self._channel)
-    self._unary_stream = _unary_stream_multi_callable(self._channel)
-    self._stream_unary = _stream_unary_multi_callable(self._channel)
-    self._stream_stream = _stream_stream_multi_callable(self._channel)
-
-  def testUnaryRequestBlockingUnaryResponse(self):
-    request = b'\x07\x08'
-    metadata = (('InVaLiD', 'UnaryRequestBlockingUnaryResponse'),)
-    expected_error_details = "metadata was invalid: %s" % metadata
-    with self.assertRaises(ValueError) as exception_context:
-      self._unary_unary(request, metadata=metadata)
-    self.assertIn(expected_error_details, str(exception_context.exception))
-
-  def testUnaryRequestBlockingUnaryResponseWithCall(self):
-    request = b'\x07\x08'
-    metadata = (('InVaLiD', 'UnaryRequestBlockingUnaryResponseWithCall'),)
-    expected_error_details = "metadata was invalid: %s" % metadata
-    with self.assertRaises(ValueError) as exception_context:
-      self._unary_unary.with_call(request, metadata=metadata)
-    self.assertIn(expected_error_details, str(exception_context.exception))
-
-  def testUnaryRequestFutureUnaryResponse(self):
-    request = b'\x07\x08'
-    metadata = (('InVaLiD', 'UnaryRequestFutureUnaryResponse'),)
-    expected_error_details = "metadata was invalid: %s" % metadata
-    response_future = self._unary_unary.future(request, metadata=metadata)
-    with self.assertRaises(grpc.RpcError) as exception_context:
-      response_future.result()
-    self.assertEqual(
-        exception_context.exception.details(), expected_error_details)
-    self.assertEqual(
-        exception_context.exception.code(), grpc.StatusCode.INTERNAL)
-    self.assertEqual(response_future.details(), expected_error_details)
-    self.assertEqual(response_future.code(), grpc.StatusCode.INTERNAL)
-
-  def testUnaryRequestStreamResponse(self):
-    request = b'\x37\x58'
-    metadata = (('InVaLiD', 'UnaryRequestStreamResponse'),)
-    expected_error_details = "metadata was invalid: %s" % metadata
-    response_iterator = self._unary_stream(request, metadata=metadata)
-    with self.assertRaises(grpc.RpcError) as exception_context:
-      next(response_iterator)
-    self.assertEqual(
-        exception_context.exception.details(), expected_error_details)
-    self.assertEqual(
-        exception_context.exception.code(), grpc.StatusCode.INTERNAL)
-    self.assertEqual(response_iterator.details(), expected_error_details)
-    self.assertEqual(response_iterator.code(), grpc.StatusCode.INTERNAL)
-
-  def testStreamRequestBlockingUnaryResponse(self):
-    request_iterator = (b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH))
-    metadata = (('InVaLiD', 'StreamRequestBlockingUnaryResponse'),)
-    expected_error_details = "metadata was invalid: %s" % metadata
-    with self.assertRaises(ValueError) as exception_context:
-      self._stream_unary(request_iterator, metadata=metadata)
-    self.assertIn(expected_error_details, str(exception_context.exception))
-
-  def testStreamRequestBlockingUnaryResponseWithCall(self):
-    request_iterator = (
-        b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH))
-    metadata = (('InVaLiD', 'StreamRequestBlockingUnaryResponseWithCall'),)
-    expected_error_details = "metadata was invalid: %s" % metadata
-    multi_callable = _stream_unary_multi_callable(self._channel)
-    with self.assertRaises(ValueError) as exception_context:
-      multi_callable.with_call(request_iterator, metadata=metadata)
-    self.assertIn(expected_error_details, str(exception_context.exception))
-
-  def testStreamRequestFutureUnaryResponse(self):
-    request_iterator = (
-        b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH))
-    metadata = (('InVaLiD', 'StreamRequestFutureUnaryResponse'),)
-    expected_error_details = "metadata was invalid: %s" % metadata
-    response_future = self._stream_unary.future(
-        request_iterator, metadata=metadata)
-    with self.assertRaises(grpc.RpcError) as exception_context:
-      response_future.result()
-    self.assertEqual(
-        exception_context.exception.details(), expected_error_details)
-    self.assertEqual(
-        exception_context.exception.code(), grpc.StatusCode.INTERNAL)
-    self.assertEqual(response_future.details(), expected_error_details)
-    self.assertEqual(response_future.code(), grpc.StatusCode.INTERNAL)
-
-  def testStreamRequestStreamResponse(self):
-    request_iterator = (
-        b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH))
-    metadata = (('InVaLiD', 'StreamRequestStreamResponse'),)
-    expected_error_details = "metadata was invalid: %s" % metadata
-    response_iterator = self._stream_stream(request_iterator, metadata=metadata)
-    with self.assertRaises(grpc.RpcError) as exception_context:
-      next(response_iterator)
-    self.assertEqual(
-        exception_context.exception.details(), expected_error_details)
-    self.assertEqual(
-        exception_context.exception.code(), grpc.StatusCode.INTERNAL)
-    self.assertEqual(response_iterator.details(), expected_error_details)
-    self.assertEqual(response_iterator.code(), grpc.StatusCode.INTERNAL)
+    def setUp(self):
+        self._channel = grpc.insecure_channel('localhost:8080')
+        self._unary_unary = _unary_unary_multi_callable(self._channel)
+        self._unary_stream = _unary_stream_multi_callable(self._channel)
+        self._stream_unary = _stream_unary_multi_callable(self._channel)
+        self._stream_stream = _stream_stream_multi_callable(self._channel)
+
+    def testUnaryRequestBlockingUnaryResponse(self):
+        request = b'\x07\x08'
+        metadata = (('InVaLiD', 'UnaryRequestBlockingUnaryResponse'),)
+        expected_error_details = "metadata was invalid: %s" % metadata
+        with self.assertRaises(ValueError) as exception_context:
+            self._unary_unary(request, metadata=metadata)
+        self.assertIn(expected_error_details, str(exception_context.exception))
+
+    def testUnaryRequestBlockingUnaryResponseWithCall(self):
+        request = b'\x07\x08'
+        metadata = (('InVaLiD', 'UnaryRequestBlockingUnaryResponseWithCall'),)
+        expected_error_details = "metadata was invalid: %s" % metadata
+        with self.assertRaises(ValueError) as exception_context:
+            self._unary_unary.with_call(request, metadata=metadata)
+        self.assertIn(expected_error_details, str(exception_context.exception))
+
+    def testUnaryRequestFutureUnaryResponse(self):
+        request = b'\x07\x08'
+        metadata = (('InVaLiD', 'UnaryRequestFutureUnaryResponse'),)
+        expected_error_details = "metadata was invalid: %s" % metadata
+        response_future = self._unary_unary.future(request, metadata=metadata)
+        with self.assertRaises(grpc.RpcError) as exception_context:
+            response_future.result()
+        self.assertEqual(exception_context.exception.details(),
+                         expected_error_details)
+        self.assertEqual(exception_context.exception.code(),
+                         grpc.StatusCode.INTERNAL)
+        self.assertEqual(response_future.details(), expected_error_details)
+        self.assertEqual(response_future.code(), grpc.StatusCode.INTERNAL)
+
+    def testUnaryRequestStreamResponse(self):
+        request = b'\x37\x58'
+        metadata = (('InVaLiD', 'UnaryRequestStreamResponse'),)
+        expected_error_details = "metadata was invalid: %s" % metadata
+        response_iterator = self._unary_stream(request, metadata=metadata)
+        with self.assertRaises(grpc.RpcError) as exception_context:
+            next(response_iterator)
+        self.assertEqual(exception_context.exception.details(),
+                         expected_error_details)
+        self.assertEqual(exception_context.exception.code(),
+                         grpc.StatusCode.INTERNAL)
+        self.assertEqual(response_iterator.details(), expected_error_details)
+        self.assertEqual(response_iterator.code(), grpc.StatusCode.INTERNAL)
+
+    def testStreamRequestBlockingUnaryResponse(self):
+        request_iterator = (b'\x07\x08'
+                            for _ in range(test_constants.STREAM_LENGTH))
+        metadata = (('InVaLiD', 'StreamRequestBlockingUnaryResponse'),)
+        expected_error_details = "metadata was invalid: %s" % metadata
+        with self.assertRaises(ValueError) as exception_context:
+            self._stream_unary(request_iterator, metadata=metadata)
+        self.assertIn(expected_error_details, str(exception_context.exception))
+
+    def testStreamRequestBlockingUnaryResponseWithCall(self):
+        request_iterator = (b'\x07\x08'
+                            for _ in range(test_constants.STREAM_LENGTH))
+        metadata = (('InVaLiD', 'StreamRequestBlockingUnaryResponseWithCall'),)
+        expected_error_details = "metadata was invalid: %s" % metadata
+        multi_callable = _stream_unary_multi_callable(self._channel)
+        with self.assertRaises(ValueError) as exception_context:
+            multi_callable.with_call(request_iterator, metadata=metadata)
+        self.assertIn(expected_error_details, str(exception_context.exception))
+
+    def testStreamRequestFutureUnaryResponse(self):
+        request_iterator = (b'\x07\x08'
+                            for _ in range(test_constants.STREAM_LENGTH))
+        metadata = (('InVaLiD', 'StreamRequestFutureUnaryResponse'),)
+        expected_error_details = "metadata was invalid: %s" % metadata
+        response_future = self._stream_unary.future(
+            request_iterator, metadata=metadata)
+        with self.assertRaises(grpc.RpcError) as exception_context:
+            response_future.result()
+        self.assertEqual(exception_context.exception.details(),
+                         expected_error_details)
+        self.assertEqual(exception_context.exception.code(),
+                         grpc.StatusCode.INTERNAL)
+        self.assertEqual(response_future.details(), expected_error_details)
+        self.assertEqual(response_future.code(), grpc.StatusCode.INTERNAL)
+
+    def testStreamRequestStreamResponse(self):
+        request_iterator = (b'\x07\x08'
+                            for _ in range(test_constants.STREAM_LENGTH))
+        metadata = (('InVaLiD', 'StreamRequestStreamResponse'),)
+        expected_error_details = "metadata was invalid: %s" % metadata
+        response_iterator = self._stream_stream(
+            request_iterator, metadata=metadata)
+        with self.assertRaises(grpc.RpcError) as exception_context:
+            next(response_iterator)
+        self.assertEqual(exception_context.exception.details(),
+                         expected_error_details)
+        self.assertEqual(exception_context.exception.code(),
+                         grpc.StatusCode.INTERNAL)
+        self.assertEqual(response_iterator.details(), expected_error_details)
+        self.assertEqual(response_iterator.code(), grpc.StatusCode.INTERNAL)
 
 
 if __name__ == '__main__':
-  unittest.main(verbosity=2)
+    unittest.main(verbosity=2)