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

Updated for max retries.

Browse Source
This commit is contained in:
Sam Sykes
2025-11-11 18:00:27 +00:00
parent 501744d7da
commit 41cf9adef4
2 changed files with 11 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
CHANGELOG.md
View File

@@ -10,7 +10,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
### Changed ### Changed
- Added support for retrying `SpeechmaticsTTSService` when it returns a 503 - Added support for retrying `SpeechmaticsTTSService` when it returns a 503
error. error. Default values in `InputParams`.
### Deprecated ### Deprecated

16
src/pipecat/services/speechmatics/tts.py
View File

@@ -46,9 +46,13 @@ class SpeechmaticsTTSService(TTSService):
SPEECHMATICS_SAMPLE_RATE = 16000 SPEECHMATICS_SAMPLE_RATE = 16000
class InputParams(BaseModel): class InputParams(BaseModel):
"""Optional input parameters for Speechmatics TTS configuration.""" """Optional input parameters for Speechmatics TTS configuration.
pass Parameters:
max_retries: Maximum number of retries for TTS requests. Defaults to 5.
"""
max_retries: int = 5
def __init__( def __init__(
self, self,
@@ -151,8 +155,11 @@ class SpeechmaticsTTSService(TTSService):
attempt=attempt, min_wait=0.25, max_wait=8.0, multiplier=0.5 attempt=attempt, min_wait=0.25, max_wait=8.0, multiplier=0.5
) )
# Increment attempt
attempt += 1
# Check if we've exceeded the maximum number of attempts # Check if we've exceeded the maximum number of attempts
if backoff_time >= 8.0: if attempt > self._params.max_retries:
raise ValueError() raise ValueError()
# Report error frame # Report error frame
@@ -163,9 +170,6 @@ class SpeechmaticsTTSService(TTSService):
# Wait before retrying # Wait before retrying
await asyncio.sleep(backoff_time) await asyncio.sleep(backoff_time)
# Increment attempt
attempt += 1
# Retry # Retry
continue continue