Update src/pipecat/processors/frame_processor.py

Co-authored-by: Mark Backman <mark@daily.co>
2024-11-19 22:37:58 -06:00
parent e00c75ce3f
commit 14893ade92
1 changed files with 2 additions and 1 deletions
--- a/src/pipecat/processors/frame_processor.py
+++ b/src/pipecat/processors/frame_processor.py
@@ -246,7 +246,8 @@ class FrameProcessor:
                await self._prev.queue_frame(frame, direction)
        except Exception as e:
            logger.exception(f"Uncaught exception in {self}: {e}")
-            raise Exception("internal_push_frame") from e
+            await self.push_error(ErrorFrame(str(e)))
+            raise

    def __create_input_task(self):
        self.__input_queue = asyncio.Queue()