From 5303f90a179e89b0da72535c59ce32024f5f3833 Mon Sep 17 00:00:00 2001 From: Gabe Joseph Date: Thu, 4 Aug 2022 10:41:16 -0600 Subject: [PATCH] Remove debug code --- distributed/utils_test.py | 4 ---- 1 file changed, 4 deletions(-) diff --git a/distributed/utils_test.py b/distributed/utils_test.py index 8c7ddd2779e..e519ef18f78 100644 --- a/distributed/utils_test.py +++ b/distributed/utils_test.py @@ -787,9 +787,7 @@ async def disconnect(addr, timeout=3, rpc_kwargs=None): rpc_kwargs = rpc_kwargs or {} async def do_disconnect(): - logger.info(f"Disconnecting {addr}") async with rpc(addr, **rpc_kwargs) as w: - logger.info(f"Disconnecting {addr} - RPC connected") # If the worker was killed hard (e.g. sigterm) during test runtime, # we do not know at this point and may not be able to connect with suppress(EnvironmentError, CommClosedError): @@ -797,13 +795,11 @@ async def do_disconnect(): # worker before a reply can be made and we will always trigger # the timeout await w.terminate(reply=False) - logger.info(f"Disconnecting {addr} - sent terminate") await asyncio.wait_for(do_disconnect(), timeout=timeout) async def disconnect_all(addresses, timeout=3, rpc_kwargs=None): - logger.info(f"Disconnecting {addresses}") await asyncio.gather(*(disconnect(addr, timeout, rpc_kwargs) for addr in addresses))