From d3d33162e830d97cc6c9125167d0f4507024fd55 Mon Sep 17 00:00:00 2001 From: Gabriel Luiz Freitas Almeida Date: Wed, 21 Jun 2023 15:04:36 -0300 Subject: [PATCH] =?UTF-8?q?=F0=9F=90=9B=20fix(chat.py):=20change=20event?= =?UTF-8?q?=20name=20from=20"node"=20to=20"message"=20in=20stream=5Fbuild?= =?UTF-8?q?=20function=20The=20event=20name=20was=20changed=20from=20"node?= =?UTF-8?q?"=20to=20"message"=20to=20better=20reflect=20the=20nature=20of?= =?UTF-8?q?=20the=20data=20being=20sent.=20The=20data=20being=20sent=20is?= =?UTF-8?q?=20a=20message=20response=20from=20the=20server,=20not=20a=20no?= =?UTF-8?q?de=20in=20the=20graph.?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/backend/langflow/api/v1/chat.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/backend/langflow/api/v1/chat.py b/src/backend/langflow/api/v1/chat.py index 2220bbeb8..be9d6802c 100644 --- a/src/backend/langflow/api/v1/chat.py +++ b/src/backend/langflow/api/v1/chat.py @@ -118,14 +118,14 @@ async def stream_build(flow_id: str): "progress": round(i / number_of_nodes, 2), } - yield str(StreamData(event="node", data=response)) + yield str(StreamData(event="message", data=response)) chat_manager.set_cache(flow_id, graph.build()) except Exception as exc: logger.error("Error while building the flow: %s", exc) yield str(StreamData(event="error", data={"error": str(exc)})) finally: - yield str(StreamData(event="end", data=final_response)) + yield str(StreamData(event="message", data=final_response)) try: return StreamingResponse(event_stream(flow_id), media_type="text/event-stream")