use the same mp_ctx

livekit · Jul 23, 2024 · c8907af · c8907af
1 parent bb80627
commit c8907af
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/livekit-agents/livekit/agents/ipc/supervised_proc.py b/livekit-agents/livekit/agents/ipc/supervised_proc.py
@@ -69,7 +69,7 @@ def __init__(
         loop: asyncio.AbstractEventLoop,
     ) -> None:
         self._loop = loop
-        log_q = mp.Queue()
+        log_q = mp_ctx.Queue()
         log_q.cancel_join_thread()
         mp_pch, mp_cch = mp_ctx.Pipe(duplex=True)