rtvi: handle all actions from the action task

pipecat-ai · Sep 24, 2024 · a483f1a · a483f1a
1 parent 2ecec1c
commit a483f1a
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/pipecat/processors/frameworks/rtvi.py b/src/pipecat/processors/frameworks/rtvi.py
@@ -521,7 +521,8 @@ async def _handle_message(self, frame: TransportMessageFrame):
                     await self._handle_update_config(message.id, update_config)
                 case "action":
                     action = RTVIActionRun.model_validate(message.data)
-                    await self._handle_action(message.id, action)
+                    action_frame = RTVIActionFrame(message_id=message.id, rtvi_action_run=action)
+                    await self._action_queue.put(action_frame)
                 case "llm-function-call-result":
                     data = RTVILLMFunctionCallResultData.model_validate(message.data)
                     await self._handle_function_call_result(data)