Fix stack dump on closed stream

livekit · Nov 1, 2024 · a1c2798 · a1c2798
1 parent 95a90f0
commit a1c2798
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/livekit-agents/livekit/agents/ipc/job_main.py b/livekit-agents/livekit/agents/ipc/job_main.py
@@ -208,7 +208,11 @@ async def _async_main(
     async def _read_ipc_task():
         nonlocal job_task
         while True:
-            msg = await channel.arecv_message(cch, proto.IPC_MESSAGES)
+            try:
+                msg = await channel.arecv_message(cch, proto.IPC_MESSAGES)
+            except duplex_unix.DuplexClosed:
+                break
+
             with contextlib.suppress(utils.aio.SleepFinished):
                 no_msg_timeout.reset()