diff --git a/src/utils/sse_manager.py b/src/utils/sse_manager.py
index 1b284d06..7fc640a4 100644
--- a/src/utils/sse_manager.py
+++ b/src/utils/sse_manager.py
@@ -19,7 +19,7 @@ async def subscribe(self, event_type: str):
         while True:
             try:
                 data = await asyncio.wait_for(self.event_queues[event_type].get(), timeout=1.0)
-                yield f"data: {data}\n\n"
+                yield f"{data}\n"
             except asyncio.TimeoutError:
                 pass