diff --git a/src/control_backend/api/v1/endpoints/logs.py b/src/control_backend/api/v1/endpoints/logs.py index 4d05039..5dad826 100644 --- a/src/control_backend/api/v1/endpoints/logs.py +++ b/src/control_backend/api/v1/endpoints/logs.py @@ -3,7 +3,6 @@ import logging import zmq from fastapi import APIRouter from fastapi.responses import StreamingResponse -from pyjabber.server_parameters import json from zmq.asyncio import Context from control_backend.core.config import settings @@ -13,6 +12,7 @@ logger = logging.getLogger(__name__) router = APIRouter() +# DO NOT LOG INSIDE THIS FUNCTION @router.get("/logs/stream") async def log_stream(): context = Context.instance() @@ -27,7 +27,6 @@ async def log_stream(): while True: _, message = await socket.recv_multipart() message = message.decode().strip() - json_data = json.dumps(message) - yield f"data: {json_data}\n\n" + yield f"data: {message}\n\n" return StreamingResponse(gen(), media_type="text/event-stream")