bugfix

dagflow/dagflow.py

@@ -312,6 +312,7 @@ where backid=${backid}$
 							})
 							break;
 				elif status in ['done', 'cancelled', 'failed']:
+					debug(f'节点完成，检查后续节点')
 					await self.node_transfer(sor, dsl, inst, ne, node, flow_def)
 					await sor.U('node_execution', {
 						'id': ne.id,
@@ -335,7 +336,7 @@ where backid=${backid}$
 
 	async def check_instance_completed(self, sor, inst):
 		sql = "select * from node_execution where instance_id=${instance_id} and type='end'"
-		recs = await sor.sqlExe(sql, {'instance_id', inst.id})
+		recs = await sor.sqlExe(sql, {'instance_id': inst.id})
 		if recs:
 			if recs[0].status == 'completed':
 				await sor.U('flow_instance', {
@@ -346,6 +347,7 @@ where backid=${backid}$
 	async def node_transfer(self, sor, dsl, inst, ne, node, flow_def):
 		nnodes = []
 		ctx = json.loads(inst.ctx)
+		debug(f'{dsl=}, {inst=}, {ne=}, {node=}')
 		for edge in dsl.get('edges', []):
 			if edge['from'] != ne.node_id:
 				continue