diff --git a/src/pipecat/processors/text_transformer.py b/src/pipecat/processors/text_transformer.py
index 39fcf6b67..79e9b885e 100644
--- a/src/pipecat/processors/text_transformer.py
+++ b/src/pipecat/processors/text_transformer.py
@@ -33,6 +33,6 @@ async def process_frame(self, frame: Frame, direction: FrameDirection):
             result = self._transform_fn(frame.text)
             if isinstance(result, Coroutine):
                 result = await result
-            await self.push_frame(result)
+            await self.push_frame(TextFrame(text=result))
         else:
             await self.push_frame(frame, direction)