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

AWSNovaSonicLLMService: pre-load audio cue in the constructor

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2025-08-29 20:25:52 -07:00
parent 65298ab792
commit e3597801d4
1 changed files with 7 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
src/pipecat/services/aws_nova_sonic/aws.py
View File

@@ -247,13 +247,14 @@ class AWSNovaSonicLLMService(LLMService):
self._ready_to_send_context = False self._ready_to_send_context = False
self._handling_bot_stopped_speaking = False self._handling_bot_stopped_speaking = False
self._triggering_assistant_response = False self._triggering_assistant_response = False
self._assistant_response_trigger_audio: Optional[bytes] = (
None # Not cleared on _disconnect()
)
self._disconnecting = False self._disconnecting = False
self._connected_time: Optional[float] = None self._connected_time: Optional[float] = None
self._wants_connection = False self._wants_connection = False
file_path = files("pipecat.services.aws_nova_sonic").joinpath("ready.wav")
with wave.open(file_path.open("rb"), "rb") as wav_file:
self._assistant_response_trigger_audio = wav_file.readframes(wav_file.getnframes())
# #
# standard AIService frame handling # standard AIService frame handling
# #
@@ -1099,20 +1100,13 @@ class AWSNovaSonicLLMService(LLMService):
self._triggering_assistant_response = True self._triggering_assistant_response = True
# Read audio bytes, if we don't already have them cached
if not self._assistant_response_trigger_audio:
file_path = files("pipecat.services.aws_nova_sonic").joinpath("ready.wav")
with wave.open(file_path.open("rb"), "rb") as wav_file:
self._assistant_response_trigger_audio = wav_file.readframes(wav_file.getnframes())
# Send the trigger audio, if we're fully connected and set up # Send the trigger audio, if we're fully connected and set up
if self._connected_time is not None: if self._connected_time:
await self._send_assistant_response_trigger() await self._send_assistant_response_trigger()
async def _send_assistant_response_trigger(self): async def _send_assistant_response_trigger(self):
if ( if not self._connected_time:
not self._assistant_response_trigger_audio or self._connected_time is None # should never happen
): # should never happen
return return
try: try: