diff --git a/src/pipecat/processors/async_generator.py b/src/pipecat/processors/async_generator.py
index 66b2a3e99..4f9bc85d0 100644
--- a/src/pipecat/processors/async_generator.py
+++ b/src/pipecat/processors/async_generator.py
@@ -26,6 +26,8 @@ class AsyncGeneratorProcessor(FrameProcessor):
     async def process_frame(self, frame: Frame, direction: FrameDirection):
         await super().process_frame(frame, direction)
 
+        await self.push_frame(frame, direction)
+
         if isinstance(frame, (CancelFrame, EndFrame)):
             await self._data_queue.put(None)
         else: