From c97643c79757a0fd7a1ac5f7c2b1d10832919b75 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Aleix=20Conchillo=20Flaqu=C3=A9?= Date: Wed, 6 Aug 2025 23:00:03 -0700 Subject: [PATCH] RivaSTTService: always use WatchdogQueue --- src/pipecat/services/riva/stt.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/pipecat/services/riva/stt.py b/src/pipecat/services/riva/stt.py index ba1af4f6f..be90e8732 100644 --- a/src/pipecat/services/riva/stt.py +++ b/src/pipecat/services/riva/stt.py @@ -168,7 +168,7 @@ class RivaSTTService(STTService): self._asr_service = riva.client.ASRService(auth) - self._queue = asyncio.Queue() + self._queue = None self._config = None self._thread_task = None self._response_task = None @@ -239,6 +239,7 @@ class RivaSTTService(STTService): riva.client.add_custom_configuration_to_config(config, self._custom_configuration) self._config = config + self._queue = WatchdogQueue(self.task_manager) if not self._thread_task: self._thread_task = self.create_task(self._thread_task_handler())