From df7dc8fdf3975ae9523ff3f0e7e5c0227ff210b9 Mon Sep 17 00:00:00 2001 From: Kasper Date: Wed, 5 Nov 2025 16:38:03 +0100 Subject: [PATCH] fix: no double json ref: N25B-242 --- src/control_backend/api/v1/endpoints/logs.py | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) 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")