From 84b7a1456bf0d06fba3c9476401049e0efb40af7 Mon Sep 17 00:00:00 2001 From: jingrow Date: Thu, 18 Sep 2025 01:38:21 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E6=B5=81=E7=A8=8B=E7=BC=96?= =?UTF-8?q?=E6=8E=92=E7=95=8C=E9=9D=A2=E7=82=B9=E5=87=BB=E6=89=A7=E8=A1=8C?= =?UTF-8?q?=E5=87=BA=E9=94=99=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- backend/app/routes/nodes.py | 5 ++++- dump.rdb | Bin 314 -> 223 bytes 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/backend/app/routes/nodes.py b/backend/app/routes/nodes.py index d47ec640..0bfc4cae 100644 --- a/backend/app/routes/nodes.py +++ b/backend/app/routes/nodes.py @@ -17,9 +17,12 @@ async def execute_node(node_type: str, request: Request, request_data: Dict[str, # 获取session cookie session_cookie = request.cookies.get('sid') + # 从context中获取flow_id + flow_id = context.get('flow_id', '') + # 使用节点执行器执行节点(支持点分隔 node_type) executor = NodeExecutor() - result = await executor.execute_node(node_type, context, inputs, config, session_cookie) + result = await executor.execute_node(node_type, flow_id, context, inputs, config, session_cookie) return result diff --git a/dump.rdb b/dump.rdb index fec90d5fa003181d82f812d4ed61b57e2273ca49..a2c77b1c65e29dcca83d29316c3c285011780c59 100644 GIT binary patch delta 142 zcmdnRbf0m8fne0fQyITFN{drdbaPX44`oAU|?ZbVs4O}Y>}FrqMKxB zW}$0hl47o#m~3jOYnp0dYMyLtVqlVHs`};6oV^h<85tNjm!u{dnpmcpo9HH5nx^WS s7?~L9CZ(8J>Kde)8yF;~7+55yCaQk9acmz%{r~^FKkxd%I`vqu0@LV=08_i-oaC zJJ%q%L=mu+`A%fC;0!g%XcaYvqPyL^JGjn-$QPBfYuLuhNx5ASpt3bYPYkN15E2D8 zx-PoO*8RL3q!5iKhoG@yK;w;^498@^n#77R2J4!ldk&BDa-BnkzLjM!cq_}HMh%f_ e4~m^qiBywVp7-$T>9EZ5)oT3k^LaAe|NaNb&q