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

In AWS Nova Sonic service, send the "interactive" user message (which triggers the bot response) only after sending the audio input start event, per the AWS team's recommendation

Browse Source
This commit is contained in:
Paul Kompfner
2026-01-16 22:43:49 -05:00
parent b4d143e39b
commit 06b3ecd2d6
1 changed files with 16 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
src/pipecat/services/aws/nova_sonic/llm.py
View File

@@ -533,21 +533,30 @@ class AWSNovaSonicLLMService(LLMService):
if system_instruction: if system_instruction:
await self._send_text_event(text=system_instruction, role=Role.SYSTEM) await self._send_text_event(text=system_instruction, role=Role.SYSTEM)
# Send conversation history # Send conversation history (except for the last message if it's from the
# user, which we'll send as interactive after starting audio input)
messages = llm_connection_params["messages"] messages = llm_connection_params["messages"]
last_user_message = None
for i, message in enumerate(messages): for i, message in enumerate(messages):
# logger.debug(f"Seeding conversation history with message: {message}") # logger.debug(f"Seeding conversation history with message: {message}")
# If last message is from user, mark it as interactive to trigger
# bot response
is_last_message = i == len(messages) - 1 is_last_message = i == len(messages) - 1
interactive = is_last_message and message.role == Role.USER if is_last_message and message.role == Role.USER:
await self._send_text_event( # Save for sending after audio input starts
text=message.text, role=message.role, interactive=interactive last_user_message = message
) else:
await self._send_text_event(text=message.text, role=message.role)
# Start audio input # Start audio input
await self._send_audio_input_start_event() await self._send_audio_input_start_event()
# Now send the last user message as interactive to trigger bot response
if last_user_message:
# logger.debug(
# f"Sending last user message as interactive to trigger bot response: {last_user_message}")
await self._send_text_event(
text=last_user_message.text, role=last_user_message.role, interactive=True
)
# Start receiving events # Start receiving events
self._receive_task = self.create_task(self._receive_task_handler()) self._receive_task = self.create_task(self._receive_task_handler())