diff --git a/tractor/_ipc.py b/tractor/_ipc.py index 70774be..511a053 100644 --- a/tractor/_ipc.py +++ b/tractor/_ipc.py @@ -716,4 +716,5 @@ async def _connect_chan( chan = Channel((host, port)) await chan.connect() yield chan - await chan.aclose() + with trio.CancelScope(shield=True): + await chan.aclose()