From bb0a1d89e4803c1958776d97157e155f9d11b52f Mon Sep 17 00:00:00 2001
From: yumoqing <yumoqing@gmail.com>
Date: Mon, 16 Mar 2026 16:32:33 +0800
Subject: [PATCH] bugfix

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

diff --git a/dagflow/dagflow.py b/dagflow/dagflow.py
index 05ceb96..677ca4b 100644
--- a/dagflow/dagflow.py
+++ b/dagflow/dagflow.py
@@ -14,7 +14,7 @@ Features:
 import asyncio
 import yaml
 from random import randint
-from appPublic.log import debug
+from appPublic.log import debug, exception, error, info
 from appPublic.timeUtils import timestampstr
 from sqlor.dbpools import get_sor_context
 
@@ -153,8 +153,9 @@ where backid=${backid}$
 				aio = await sor.sqlExe(sql,{
 					'backid': self.backid
 				})
+			debug(f'aio={aio}')
 			for r in aio:
-				await elf.step(r)
+				await self.step(r)
 			await asyncio.sleep(1)
 
 	async def create_definition(self, org_id, name, description, version, dsl_text, ctxfields):