format
This commit is contained in:
@@ -126,10 +126,10 @@ class TavusApi:
|
|||||||
response = await r.json()
|
response = await r.json()
|
||||||
logger.debug(f"Fetched Tavus persona: {response}")
|
logger.debug(f"Fetched Tavus persona: {response}")
|
||||||
return response["persona_name"]
|
return response["persona_name"]
|
||||||
|
|
||||||
async def _validate_persona(self, persona_id: str):
|
async def _validate_persona(self, persona_id: str):
|
||||||
"""Validate that the persona's microphone is enabled.
|
"""Validate that the persona's microphone is enabled.
|
||||||
|
|
||||||
Args:
|
Args:
|
||||||
persona_id: ID of the persona to validate.
|
persona_id: ID of the persona to validate.
|
||||||
"""
|
"""
|
||||||
@@ -143,9 +143,13 @@ class TavusApi:
|
|||||||
logger.debug(f"Fetched Tavus persona: {response}")
|
logger.debug(f"Fetched Tavus persona: {response}")
|
||||||
try:
|
try:
|
||||||
transport_settings = response.get("layers", {}).get("transport", {})
|
transport_settings = response.get("layers", {}).get("transport", {})
|
||||||
microphone_enabled = transport_settings.get("input_settings", {}).get("microphone", "")
|
microphone_enabled = transport_settings.get("input_settings", {}).get(
|
||||||
|
"microphone", ""
|
||||||
|
)
|
||||||
if microphone_enabled != "enabled":
|
if microphone_enabled != "enabled":
|
||||||
raise Exception("Microphone is not enabled for this persona. Please update the persona or use the persona pipecat-stream.")
|
raise Exception(
|
||||||
|
"Microphone is not enabled for this persona. Please update the persona or use the persona pipecat-stream."
|
||||||
|
)
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
logger.error(f"Error validating persona {persona_id}: {e}")
|
logger.error(f"Error validating persona {persona_id}: {e}")
|
||||||
raise e
|
raise e
|
||||||
|
|||||||
Reference in New Issue
Block a user