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

fix some bugs after testing changes

Browse Source
This commit is contained in:
Mike Seese
2026-01-05 11:49:52 -08:00
parent 67fdb0b659
commit d2df324f29
2 changed files with 11 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/pipecat/services/hathora/stt.py
View File

@@ -37,14 +37,14 @@ class HathoraSTTService(SegmentedSTTService):
Parameters: Parameters:
language: Language code (if supported by model). language: Language code (if supported by model).
model_config: Some models support additional config, refer to config: Some models support additional config, refer to
[docs](https://models.hathora.dev) for each model to see [docs](https://models.hathora.dev) for each model to see
what is supported. what is supported.
base_url: Base API URL for the Hathora STT service. base_url: Base API URL for the Hathora STT service.
""" """
language: Optional[str] = None language: Optional[str] = None
model_config: Optional[list[ConfigOption]] = None config: Optional[list[ConfigOption]] = None
base_url: str = "https://api.models.hathora.dev/inference/v1/stt", base_url: str = "https://api.models.hathora.dev/inference/v1/stt",
def __init__( def __init__(
@@ -76,7 +76,7 @@ class HathoraSTTService(SegmentedSTTService):
self._settings = { self._settings = {
"language": params.language, "language": params.language,
"model_config": params.model_config, "config": params.config,
} }
self.set_model_name(model) self.set_model_name(model)
@@ -117,9 +117,9 @@ class HathoraSTTService(SegmentedSTTService):
if self._settings["language"] is not None: if self._settings["language"] is not None:
payload["language"] = self._settings["language"] payload["language"] = self._settings["language"]
if self._settings["model_config"] is not None: if self._settings["config"] is not None:
payload["model_config"] = [ payload["model_config"] = [
{"name": option.name, "value": option.value} for option in self._settings["model_config"] {"name": option.name, "value": option.value} for option in self._settings["config"]
] ]
base64_audio = base64.b64encode(audio).decode("utf-8") base64_audio = base64.b64encode(audio).decode("utf-8")

12
src/pipecat/services/hathora/tts.py
View File

@@ -56,14 +56,14 @@ class HathoraTTSService(TTSService):
Parameters: Parameters:
speed: Speech speed multiplier (if supported by model). speed: Speech speed multiplier (if supported by model).
model_config: Some models support additional config, refer to config: Some models support additional config, refer to
[docs](https://models.hathora.dev) for each model to see [docs](https://models.hathora.dev) for each model to see
what is supported. what is supported.
base_url: Base API URL for the Hathora TTS service. base_url: Base API URL for the Hathora TTS service.
""" """
speed: Optional[float] = None speed: Optional[float] = None
model_config: Optional[list[ConfigOption]] = None config: Optional[list[ConfigOption]] = None
base_url: str = "https://api.models.hathora.dev/inference/v1/tts", base_url: str = "https://api.models.hathora.dev/inference/v1/tts",
def __init__( def __init__(
@@ -97,7 +97,7 @@ class HathoraTTSService(TTSService):
self._settings = { self._settings = {
"speed": params.speed, "speed": params.speed,
"model_config": params.model_config, "config": params.config,
} }
self.set_model_name(model) self.set_model_name(model)
@@ -125,7 +125,7 @@ class HathoraTTSService(TTSService):
await self.start_processing_metrics() await self.start_processing_metrics()
await self.start_ttfb_metrics() await self.start_ttfb_metrics()
url = f"{self.base_url}" url = f"{self._base_url}"
payload = {"model": self._model, "text": text} payload = {"model": self._model, "text": text}
@@ -133,9 +133,9 @@ class HathoraTTSService(TTSService):
payload["voice"] = self._voice_id payload["voice"] = self._voice_id
if self._settings["speed"] is not None: if self._settings["speed"] is not None:
payload["speed"] = self._settings["speed"] payload["speed"] = self._settings["speed"]
if self._settings["model_config"] is not None: if self._settings["config"] is not None:
payload["model_config"] = [ payload["model_config"] = [
{"name": option.name, "value": option.value} for option in self._settings["model_config"] {"name": option.name, "value": option.value} for option in self._settings["config"]
] ]
yield TTSStartedFrame() yield TTSStartedFrame()