From 85e572e2d89cfdef6801a96ead5c21783344d6ed Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Aleix=20Conchillo=20Flaqu=C3=A9?= Date: Thu, 30 Jan 2025 13:10:47 -0800 Subject: [PATCH] gladia: cleanup receive messages task --- src/pipecat/services/gladia.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/pipecat/services/gladia.py b/src/pipecat/services/gladia.py index e240252a2..3cdeebd3c 100644 --- a/src/pipecat/services/gladia.py +++ b/src/pipecat/services/gladia.py @@ -186,10 +186,12 @@ class GladiaSTTService(STTService): await super().stop(frame) await self._send_stop_recording() await self._websocket.close() + await self.wait_for_task(self._receive_task) async def cancel(self, frame: CancelFrame): await super().cancel(frame) await self._websocket.close() + await self.cancel_task(self._receive_task) async def run_stt(self, audio: bytes) -> AsyncGenerator[Frame, None]: await self.start_processing_metrics()