diff options
Diffstat (limited to 'src/python/grpcio_test/grpc_test/_adapter/_low_test.py')
| -rw-r--r-- | src/python/grpcio_test/grpc_test/_adapter/_low_test.py | 23 |
1 files changed, 13 insertions, 10 deletions
diff --git a/src/python/grpcio_test/grpc_test/_adapter/_low_test.py b/src/python/grpcio_test/grpc_test/_adapter/_low_test.py index 70149127da..8115cd0e83 100644 --- a/src/python/grpcio_test/grpc_test/_adapter/_low_test.py +++ b/src/python/grpcio_test/grpc_test/_adapter/_low_test.py @@ -34,6 +34,7 @@ import unittest from grpc import _grpcio_metadata from grpc._adapter import _types from grpc._adapter import _low +from grpc_test import test_common def wait_for_events(completion_queues, deadline): @@ -140,16 +141,16 @@ class InsecureServerInsecureClient(unittest.TestCase): self.assertIsInstance(request_event.call, _low.Call) self.assertIs(server_request_tag, request_event.tag) self.assertEqual(1, len(request_event.results)) - received_initial_metadata = dict(request_event.results[0].initial_metadata) + received_initial_metadata = request_event.results[0].initial_metadata # Check that our metadata were transmitted - self.assertEqual( - dict(client_initial_metadata), - dict((x, received_initial_metadata[x]) - for x in zip(*client_initial_metadata)[0])) + self.assertTrue(test_common.metadata_transmitted(client_initial_metadata, + received_initial_metadata)) # Check that Python's user agent string is a part of the full user agent # string + received_initial_metadata_dict = dict(received_initial_metadata) + self.assertIn('user-agent', received_initial_metadata_dict) self.assertIn('Python-gRPC-{}'.format(_grpcio_metadata.__version__), - received_initial_metadata['user-agent']) + received_initial_metadata_dict['user-agent']) self.assertEqual(method, request_event.call_details.method) self.assertEqual(host, request_event.call_details.host) self.assertLess(abs(deadline - request_event.call_details.deadline), @@ -193,13 +194,15 @@ class InsecureServerInsecureClient(unittest.TestCase): self.assertNotIn(client_result.type, found_client_op_types) found_client_op_types.add(client_result.type) if client_result.type == _types.OpType.RECV_INITIAL_METADATA: - self.assertEqual(dict(server_initial_metadata), - dict(client_result.initial_metadata)) + self.assertTrue( + test_common.metadata_transmitted(server_initial_metadata, + client_result.initial_metadata)) elif client_result.type == _types.OpType.RECV_MESSAGE: self.assertEqual(response, client_result.message) elif client_result.type == _types.OpType.RECV_STATUS_ON_CLIENT: - self.assertEqual(dict(server_trailing_metadata), - dict(client_result.trailing_metadata)) + self.assertTrue( + test_common.metadata_transmitted(server_trailing_metadata, + client_result.trailing_metadata)) self.assertEqual(server_status_details, client_result.status.details) self.assertEqual(server_status_code, client_result.status.code) self.assertEqual(set([ |