Skip to content

Commit 555f4b2

Browse files
committed
Close receive_stream after task group has exited.
1 parent ee8b768 commit 555f4b2

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

ipykernel/kernelbase.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -452,6 +452,7 @@ async def shell_main(self, subshell_id: str | None):
452452
self._send_exec_request.pop(socket, None)
453453
self.set_trait("asyncio_event_loop", None)
454454
await send_stream.aclose()
455+
await receive_stream.aclose()
455456

456457
async def _execute_request_handler(self, receive_stream: MemoryObjectReceiveStream):
457458
async with receive_stream:

0 commit comments

Comments
 (0)