From 8ea252c0333f50e3c759e39d1d022f791c5af7c7 Mon Sep 17 00:00:00 2001 From: Gabriel Luiz Freitas Almeida Date: Tue, 27 Feb 2024 18:13:08 -0300 Subject: [PATCH] Add flow_id parameter to Graph.from_payload() method --- src/backend/langflow/processing/process.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/backend/langflow/processing/process.py b/src/backend/langflow/processing/process.py index 69e47b242..aa419b962 100644 --- a/src/backend/langflow/processing/process.py +++ b/src/backend/langflow/processing/process.py @@ -269,6 +269,7 @@ async def build_graph_and_generate_result( async def run_graph( graph: Union["Graph", dict], + flow_id: str, session_id: str, inputs: Optional[Union[dict, List[dict]]] = None, artifacts: Optional[Dict[str, Any]] = None, @@ -276,7 +277,8 @@ async def run_graph( ): """Run the graph and generate the result""" if isinstance(graph, dict): - graph = Graph.from_payload(graph) + graph = Graph.from_payload(graph, flow_id=flow_id) + outputs = await graph.run(inputs) if session_id and session_service: session_service.update_session(session_id, (graph, artifacts))