From 3bbbdf59e58aa0fb0a03a7eae9b562220af6615a Mon Sep 17 00:00:00 2001
From: yumoqing <yumoqing@gmail.com>
Date: Tue, 17 Mar 2026 17:53:04 +0800
Subject: [PATCH] bugfix

---
 dagflow/dagflow.py | 15 ++++++++-------
 dagflow/init.py    |  2 +-
 2 files changed, 9 insertions(+), 8 deletions(-)

diff --git a/dagflow/dagflow.py b/dagflow/dagflow.py
index ebbc1f5..1bd9a1e 100644
--- a/dagflow/dagflow.py
+++ b/dagflow/dagflow.py
@@ -17,6 +17,7 @@ import yaml
 from random import randint
 from appPublic.log import debug, exception, error, info
 from appPublic.timeUtils import timestampstr
+from appPublic.dictObject import DictObject
 from sqlor.dbpools import get_sor_context
 from asteval import Interpreter
 
@@ -367,13 +368,13 @@ where backid=${backid}$
 		try:
 			f = partial(self.task_success_callback, ne.id)
 			ef = partial(self.task_error_callback, ne.id)
-			params = {
-				prompt: sub_ctx,
-				callerid: users[0].id,
-				callerorgid: users[0].orgid,
-				callback:f,
-				errback: ef
-			}
+			params = DictObject(**{
+				"prompt": sub_ctx,
+				"callerid": users[0].id,
+				"callerorgid": users[0].orgid,
+				"callback":f,
+				"errback": ef
+			})
 			asyncio.create_task(env.run_skillagent, params)
 		except Exception as e:
 			await self.task_error_callback(ne.id, str(e))
diff --git a/dagflow/init.py b/dagflow/init.py
index a05179f..14dabbf 100644
--- a/dagflow/init.py
+++ b/dagflow/init.py
@@ -18,7 +18,7 @@ from .dagflow import (
 async def run_skillagent(params):
 	i = randint(0,10)
 	await asyncio.sleep(i)
-	if i<= 7:
+	if i <= 7:
 		f = params['callback']
 		data = {'data1': 'test'}
 		debug(f'任务模拟完成，返回数据={data}')