From 387c2c7d613561a85e4cded6bfec2fd64c04a188 Mon Sep 17 00:00:00 2001 From: Lidi Zheng Date: Fri, 31 Jan 2020 13:09:26 -0800 Subject: [PATCH] Further reduce the server number to 5 --- .../grpcio_tests/tests_aio/unit/channel_argument_test.py | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/src/python/grpcio_tests/tests_aio/unit/channel_argument_test.py b/src/python/grpcio_tests/tests_aio/unit/channel_argument_test.py index 565c136bc23..8bf2dc8b1f1 100644 --- a/src/python/grpcio_tests/tests_aio/unit/channel_argument_test.py +++ b/src/python/grpcio_tests/tests_aio/unit/channel_argument_test.py @@ -38,7 +38,7 @@ _OPTIONS = ( (_DISABLE_REUSE_PORT, ((_SOCKET_OPT_SO_REUSEPORT, 0),)), ) -_NUM_SERVER_CREATED = 10 +_NUM_SERVER_CREATED = 5 _GRPC_ARG_MAX_RECEIVE_MESSAGE_LENGTH = 'grpc.max_receive_message_length' _MAX_MESSAGE_LENGTH = 1024 @@ -120,11 +120,13 @@ class TestChannelArgument(AioTestBase): async def test_client(self): # Do not segfault, or raise exception! - aio.insecure_channel('[::]:0', options=_TEST_CHANNEL_ARGS) + channel = aio.insecure_channel('[::]:0', options=_TEST_CHANNEL_ARGS) + await channel.close() async def test_server(self): # Do not segfault, or raise exception! - aio.server(options=_TEST_CHANNEL_ARGS) + server = aio.server(options=_TEST_CHANNEL_ARGS) + await server.stop(None) async def test_invalid_client_args(self): for invalid_arg in _INVALID_TEST_CHANNEL_ARGS: