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

processors(realtime-ai): send a successful response for every command

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2024-07-19 16:57:00 -07:00
parent 32170b47d9
commit 13827e1282
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/pipecat/processors/frameworks/realtimeai.py
View File

@@ -175,6 +175,9 @@ class RealtimeAIProcessor(FrameProcessor):
await self._handle_llm_update_context(message.data.llm)
case "tts-speak":
await self._handle_tts_speak(message.data.tts)
# Send a message to indicate we successfully executed the command.
await self._send_response(message.type, True)
except ValidationError as e:
await self._send_response(message.type, False, f"invalid message: {e}")
@@ -219,10 +222,6 @@ class RealtimeAIProcessor(FrameProcessor):
# as the initial one.
start_frame = dataclasses.replace(self._start_frame)
await self.push_frame(start_frame)
# We now send a message to indicate we successfully initialized
# the pipelines.
await self._send_response("setup", True)
except Exception as e:
await self._send_response("setup", False, f"unable to create pipeline: {e}")