diff --git a/dagflow/dagflow.py b/dagflow/dagflow.py
index e492eeb..d9c4a5f 100644
--- a/dagflow/dagflow.py
+++ b/dagflow/dagflow.py
@@ -280,6 +280,7 @@ where backid=${backid}$
 			active_nes = await sor.sqlExe(sql, {
 				'instance_id': inst.id
 			})
+			debug(f'活动节点：{active_nes}')
 			for ne in active_nes:
 				node_id = ne.node_id
 				node = dsl['nodes'][node_id]
@@ -330,6 +331,7 @@ where backid=${backid}$
 						})
 					elif status == 'failed':
 						debug(f'节点执行失败，需要运维人员参与')
+				debug(f'{ne.node_id}处理完成')
 				
 
 	def build_node_input_ctx(self, inst, ne):