diff --git a/src/pipecat/processors/frame_processor.py b/src/pipecat/processors/frame_processor.py
index 9f614ba85..c6e73b66c 100644
--- a/src/pipecat/processors/frame_processor.py
+++ b/src/pipecat/processors/frame_processor.py
@@ -246,6 +246,7 @@ 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
 
     def __create_input_task(self):
         self.__input_queue = asyncio.Queue()