wx44wx/pipecat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

use FrameProcessor class methods

Browse Source
This commit is contained in:
Martin Schweiger
2025-05-30 09:40:46 +08:00
parent 096e854d50
commit 7f2e848a5c
1 changed files with 2 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/pipecat/services/assemblyai/stt.py
View File

@@ -132,7 +132,7 @@ class AssemblyAISTTService(STTService):
extra_headers=headers, extra_headers=headers,
) )
self._connected = True self._connected = True
self._receive_task = asyncio.create_task(self._receive_task_handler()) self._receive_task = self.create_task(self._receive_task_handler())
except Exception as e: except Exception as e:
logger.error(f"Failed to connect to AssemblyAI: {e}") logger.error(f"Failed to connect to AssemblyAI: {e}")
self._connected = False self._connected = False
@@ -166,11 +166,7 @@ class AssemblyAISTTService(STTService):
logger.warning(f"Error during termination handshake: {e}") logger.warning(f"Error during termination handshake: {e}")
if self._receive_task: if self._receive_task:
self._receive_task.cancel() await self.cancel_task(self._receive_task)
try:
await self._receive_task
except asyncio.CancelledError:
pass
await self._websocket.close() await self._websocket.close()