From f239f76ebe16e7a379e3bf6571d21c433ad3ca82 Mon Sep 17 00:00:00 2001
From: yumoqing <yumoqing@gmail.com>
Date: Tue, 17 Mar 2026 11:45:30 +0800
Subject: [PATCH] bugfix

---
 dagflow/dagflow.py | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/dagflow/dagflow.py b/dagflow/dagflow.py
index 30769b8..70bb47b 100644
--- a/dagflow/dagflow.py
+++ b/dagflow/dagflow.py
@@ -363,6 +363,8 @@ where backid=${backid}$
 
 		if len(nnodes) == 0:
 			debug(f'{ne=}, {edge}, 没有找到下一个节点')
+			return
+		debug(f'{nnodes=}, 找到的下节点。。。。。')
 		for node_id, ctx_ext, edge in nnodes:
 			node = dsl['nodes'][node_id]
 			if isinstance(ctx_ext, dict) or isinstance(ctx_ext, list):
@@ -375,6 +377,7 @@ where backid=${backid}$
 					'id': id,
 					'type': node['type'],
 					'inst_round': inst.round,
+					'instance_id': inst.id,
 					'org_id': inst.org_id,
 					'node_id': node_id,
 					'input_ctx': node.get('input_ctx'),
@@ -402,9 +405,11 @@ where backid=${backid}$
 					})
 				elif node['type'] == 'end':
 					await self.create_end_node_execution(sor, inst)
+					debug('f'{node=}是终点节点，直接结束')
 					continue
 
 				await sor.C('node_execution', ns)
+				debug(f'{ns=} 节点创建完成')
 			else:
 				debug(f'{node=}, {edge=}, {inst=}is_ok_to_create_new_node_exe() 返回了{x}')