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

Fix Deepgram STT compatibility with deepgram-sdk 6.1.0

Browse Source 
The SDK now requires explicit message objects for send_keep_alive,
send_close_stream, and send_finalize instead of no-arg calls.
This commit is contained in:
Mark Backman
2026-03-27 14:40:48 -04:00
parent a8bfc23d3a
commit 6422661d08
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/pipecat/services/deepgram/stt.py
View File

@@ -41,6 +41,9 @@ try:
from deepgram import AsyncDeepgramClient from deepgram import AsyncDeepgramClient
from deepgram.core.events import EventType from deepgram.core.events import EventType
from deepgram.listen.v1.types import ( from deepgram.listen.v1.types import (
ListenV1CloseStream,
ListenV1Finalize,
ListenV1KeepAlive,
ListenV1Results, ListenV1Results,
ListenV1SpeechStarted, ListenV1SpeechStarted,
ListenV1UtteranceEnd, ListenV1UtteranceEnd,
@@ -658,7 +661,7 @@ class DeepgramSTTService(STTService):
self._connection = None self._connection = None
if connection: if connection:
await connection.send_close_stream() await connection.send_close_stream(ListenV1CloseStream(type="CloseStream"))
await self.cancel_task(self._connection_task) await self.cancel_task(self._connection_task)
self._connection_task = None self._connection_task = None
@@ -703,7 +706,7 @@ class DeepgramSTTService(STTService):
await asyncio.sleep(5) await asyncio.sleep(5)
if self._connection: if self._connection:
try: try:
await self._connection.send_keep_alive() await self._connection.send_keep_alive(ListenV1KeepAlive(type="KeepAlive"))
logger.trace(f"{self}: Sent keepalive") logger.trace(f"{self}: Sent keepalive")
except Exception as e: except Exception as e:
logger.warning(f"{self}: Keepalive failed: {e}") logger.warning(f"{self}: Keepalive failed: {e}")
@@ -800,5 +803,5 @@ class DeepgramSTTService(STTService):
# Mark that we're awaiting a from_finalize response # Mark that we're awaiting a from_finalize response
if self._connection: if self._connection:
self.request_finalize() self.request_finalize()
await self._connection.send_finalize() await self._connection.send_finalize(ListenV1Finalize(type="Finalize"))
logger.trace(f"Triggered finalize event on: {frame.name=}, {direction=}") logger.trace(f"Triggered finalize event on: {frame.name=}, {direction=}")