processors(rtvi): handle ErrorFrames

2024-08-15 15:23:31 -07:00
parent 5d71c50080
commit 31577252f3
1 changed files with 4 additions and 0 deletions
--- a/src/pipecat/processors/frameworks/rtvi.py
+++ b/src/pipecat/processors/frameworks/rtvi.py
@@ -15,6 +15,7 @@ from pipecat.frames.frames import (
    BotStoppedSpeakingFrame,
    CancelFrame,
    EndFrame,
+    ErrorFrame,
    Frame,
    InterimTranscriptionFrame,
    StartFrame,
@@ -333,6 +334,9 @@ class RTVIProcessor(FrameProcessor):
        if isinstance(frame, CancelFrame):
            await self._cancel(frame)
            await self.push_frame(frame, direction)
+        elif isinstance(frame, ErrorFrame):
+            await self.send_error(frame.error)
+            await self.push_frame(frame, direction)
        # All other system frames
        elif isinstance(frame, SystemFrame):
            await self.push_frame(frame, direction)