update pool configuration for deepgram and cartesia (#1605)

jayeshp19 · web-flow · commit 6fb681b4607b · 2025-03-06T01:12:44.000+05:30
diff --git a/.changeset/brave-sheep-taste.md b/.changeset/brave-sheep-taste.md
@@ -0,0 +1,6 @@
+---
+"livekit-plugins-cartesia": patch
+"livekit-plugins-deepgram": patch
+---
+
+update pool configuration for deepgram and cartesia
diff --git a/livekit-plugins/livekit-plugins-cartesia/livekit/plugins/cartesia/tts.py b/livekit-plugins/livekit-plugins-cartesia/livekit/plugins/cartesia/tts.py
@@ -127,6 +127,8 @@ def __init__(
         self._pool = utils.ConnectionPool[aiohttp.ClientWebSocketResponse](
             connect_cb=self._connect_ws,
             close_cb=self._close_ws,
+            max_session_duration=300,
+            mark_refreshed_on_get=True,
         )
         self._streams = weakref.WeakSet[SynthesizeStream]()
 
diff --git a/livekit-plugins/livekit-plugins-deepgram/livekit/plugins/deepgram/tts.py b/livekit-plugins/livekit-plugins-deepgram/livekit/plugins/deepgram/tts.py
@@ -86,6 +86,7 @@ def __init__(
             connect_cb=self._connect_ws,
             close_cb=self._close_ws,
             max_session_duration=3600,  # 1 hour
+            mark_refreshed_on_get=False,
         )
 
     async def _connect_ws(self) -> aiohttp.ClientWebSocketResponse:

Original file line number	Diff line number	Diff line change
`@@ -127,6 +127,8 @@ def __init__(`
`127`	`127`	`self._pool = utils.ConnectionPool[aiohttp.ClientWebSocketResponse](`
`128`	`128`	`connect_cb=self._connect_ws,`
`129`	`129`	`close_cb=self._close_ws,`
	`130`	`+ max_session_duration=300,`
	`131`	`+ mark_refreshed_on_get=True,`
`130`	`132`	`)`
`131`	`133`	`self._streams = weakref.WeakSet[SynthesizeStream]()`
`132`	`134`
Original file line number	Diff line number	Diff line change
`@@ -86,6 +86,7 @@ def __init__(`
`86`	`86`	`connect_cb=self._connect_ws,`
`87`	`87`	`close_cb=self._close_ws,`
`88`	`88`	`max_session_duration=3600, # 1 hour`
	`89`	`+ mark_refreshed_on_get=False,`
`89`	`90`	`)`
`90`	`91`
`91`	`92`	`async def _connect_ws(self) -> aiohttp.ClientWebSocketResponse:`