diff --git a/dagflow/dagflow.py b/dagflow/dagflow.py
index f6c6289..32d94af 100644
--- a/dagflow/dagflow.py
+++ b/dagflow/dagflow.py
@@ -381,7 +381,7 @@ where backid=${backid}$
 				"callerid": users[0].id,
 				"callerorgid": users[0].orgid
 			})
-			asyncio.create_task(self.autorun_task(ne_id, params))
+			asyncio.create_task(self.autorun_task(ne.id, params))
 		except Exception as e:
 			await self.task_error_callback(ne.id, str(e))
 	# ------------------------------