From 015765960c9488b615e48396efe0850b3e345157 Mon Sep 17 00:00:00 2001
From: yumoqing <yumoqing@gmail.com>
Date: Tue, 17 Mar 2026 17:26:42 +0800
Subject: [PATCH] bugfix

---
 dagflow/dagflow.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/dagflow/dagflow.py b/dagflow/dagflow.py
index f8d3856..79519cb 100644
--- a/dagflow/dagflow.py
+++ b/dagflow/dagflow.py
@@ -315,7 +315,7 @@ where backid=${backid}$
 							flg = await self.is_ok_to_step_next(sor, node, edges, inst)
 							if flg:
 								debug(f'{ne.node_id}可以进入下一步')
-								await self.start_running(sor, inst, ne, node)
+								await self.start_running(sor, inst, ne)
 							else:
 								debug(f'{ne.id=}, {node=}, {edges=}不能走下一步')
 						elif ntype == 'subflow':
@@ -580,7 +580,7 @@ where instance_id=${instance_id}$
 				ne.output = None
 			await sor.U('node_execution', ne)
 
-	async def start_running(self, sor, ne, edges, inst):
+	async def start_running(self, sor, inst, ne):
 		debug(f'{ne.node_id}节点运行')
 		await sor.R('node_execution', {
 			'id': ne['id'],