From c8907af3381aed34b5f44409b223318406d3cc59 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?The=CC=81o=20Monnom?= Date: Wed, 24 Jul 2024 00:46:58 +0200 Subject: [PATCH] use the same mp_ctx --- livekit-agents/livekit/agents/ipc/supervised_proc.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/livekit-agents/livekit/agents/ipc/supervised_proc.py b/livekit-agents/livekit/agents/ipc/supervised_proc.py index d62883c5c..bc87baa36 100644 --- 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)