From 0eaed5bbcbecf0bb71dd1dbf3d679af2d96f077c Mon Sep 17 00:00:00 2001 From: Gabriel Luiz Freitas Almeida Date: Tue, 20 Feb 2024 16:59:26 -0300 Subject: [PATCH] Update ResultDict to ResultData in build_vertex function --- src/backend/langflow/services/socket/utils.py | 15 +++++++++++---- 1 file changed, 11 insertions(+), 4 deletions(-) diff --git a/src/backend/langflow/services/socket/utils.py b/src/backend/langflow/services/socket/utils.py index 03b609919..38f1cf82b 100644 --- a/src/backend/langflow/services/socket/utils.py +++ b/src/backend/langflow/services/socket/utils.py @@ -3,7 +3,7 @@ from typing import Callable import socketio from langflow.api.utils import format_elapsed_time -from langflow.api.v1.schemas import ResultDict, VertexBuildResponse +from langflow.api.v1.schemas import ResultData, VertexBuildResponse from langflow.graph.graph.base import Graph from langflow.graph.vertex.base import StatelessVertex from langflow.services.database.models.flow.model import Flow @@ -73,11 +73,16 @@ async def build_vertex( artifacts = vertex.artifacts timedelta = time.perf_counter() - start_time duration = format_elapsed_time(timedelta) - result_dict = ResultDict(results=result_dict, artifacts=artifacts, duration=duration, timedelta=timedelta) + result_dict = ResultData( + results=result_dict, + artifacts=artifacts, + duration=duration, + timedelta=timedelta, + ) except Exception as exc: params = str(exc) valid = False - result_dict = ResultDict(results={}) + result_dict = ResultData(results={}) artifacts = {} set_cache(flow_id, graph) await log_vertex_build( @@ -90,7 +95,9 @@ async def build_vertex( ) # Emit the vertex build response - response = VertexBuildResponse(valid=valid, params=params, id=vertex.id, data=result_dict) + response = VertexBuildResponse( + valid=valid, params=params, id=vertex.id, data=result_dict + ) await sio.emit("vertex_build", data=response.model_dump(), to=sid) except Exception as exc: