updates

livekit · Dec 25, 2024 · e7529f0 · e7529f0
1 parent 94ac7e8
commit e7529f0
Show file tree

Hide file tree

Showing 3 changed files with 18 additions and 3 deletions.
diff --git a/.changeset/gorgeous-parrots-doubt.md b/.changeset/gorgeous-parrots-doubt.md
@@ -0,0 +1,13 @@
+---
+"livekit-plugins-assemblyai": patch
+"livekit-plugins-elevenlabs": patch
+"livekit-plugins-cartesia": patch
+"livekit-plugins-deepgram": patch
+"livekit-plugins-google": patch
+"livekit-plugins-openai": patch
+"livekit-plugins-playai": patch
+"livekit-plugins-azure": patch
+"livekit-agents": patch
+---
+
+Support Multisegments for TTS input
diff --git a/livekit-agents/livekit/agents/tts/tts.py b/livekit-agents/livekit/agents/tts/tts.py
@@ -75,7 +75,6 @@ def synthesize(
         text: str,
         *,
         conn_options: APIConnectOptions = DEFAULT_API_CONNECT_OPTIONS,
-        segment_id: str | None = None,
     ) -> ChunkedStream: ...
 
     def stream(

diff --git a/livekit-plugins/livekit-plugins-deepgram/livekit/plugins/deepgram/tts.py b/livekit-plugins/livekit-plugins-deepgram/livekit/plugins/deepgram/tts.py
@@ -305,7 +305,7 @@ async def _connection_timeout():
                 wait_reconnect_task = asyncio.create_task(self._reconnect_event.wait())
                 connection_timeout_task = asyncio.create_task(_connection_timeout())
                 try:
-                    done, pending = await asyncio.wait(
+                    done, _ = await asyncio.wait(
                         [
                             asyncio.gather(*tasks),
                             wait_reconnect_task,
@@ -316,7 +316,10 @@ async def _connection_timeout():
 
                     # propagate exceptions from completed tasks
                     for task in done:
-                        if task != wait_reconnect_task:
+                        if (
+                            task != wait_reconnect_task
+                            and task != connection_timeout_task
+                        ):
                             task.result()
 
                     if wait_reconnect_task not in done: