From 6b19f14ee8e2402ab32d95a5b5222f77503ef0d0 Mon Sep 17 00:00:00 2001
From: yumoqing <yumoqing@gmail.com>
Date: Fri, 13 Mar 2026 14:40:59 +0800
Subject: [PATCH] bugfix

---
 dagflow/dagflow.py | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git a/dagflow/dagflow.py b/dagflow/dagflow.py
index 53d52c6..ab05fee 100644
--- a/dagflow/dagflow.py
+++ b/dagflow/dagflow.py
@@ -360,13 +360,11 @@ where backid=${backid}$
 						'subinst_id': subinst_id
 					})
 				elif node['type'] == 'end':
-					ns.update('
 					await self.create_end_node_execution(sor, inst)
+					continue
 
 				await sor.C('node_execution', ns)
 
-			if node.join
-
 	async def is_ok_to_create_new_node_exe(self, sor, node, edges, inst):
 		join = node.get('join)
 		if join is None: