Shield channel closing in `_connect_chan()`

runtime_to_msgspec
Tyler Goodlet 2024-05-20 16:11:59 -04:00
parent 30afcd2b6b
commit 60fc43e530
1 changed files with 2 additions and 1 deletions

View File

@ -716,4 +716,5 @@ async def _connect_chan(
chan = Channel((host, port)) chan = Channel((host, port))
await chan.connect() await chan.connect()
yield chan yield chan
with trio.CancelScope(shield=True):
await chan.aclose() await chan.aclose()