Shield channel closing in `_connect_chan()`

2024-05-20 16:11:59 -04:00 · 2024-05-20 16:11:59 -04:00 · 09948d71c6
parent 452094df27
commit 09948d71c6
1 changed files with 2 additions and 1 deletions
--- 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()