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

---
 dagflow/dagflow.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/dagflow/dagflow.py b/dagflow/dagflow.py
index 525396a..2d29f0c 100644
--- a/dagflow/dagflow.py
+++ b/dagflow/dagflow.py
@@ -154,7 +154,7 @@ where backid=${backid}$
 					'backid': self.backid
 				})
 			for r in aio:
-				self.step(r)
+				await elf.step(r)
 			await asyncio.sleep(1)
 
 	async def create_definition(self, org_id, name, description, version, dsl_text, ctxfields):