yumoqing/dagflow
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bugfix

Browse Source
This commit is contained in:
yumoqing 2026-03-17 17:53:04 +08:00
parent 1a0b00e613
commit 3bbbdf59e5
2 changed files with 9 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
dagflow/dagflow.py
View File

@ -17,6 +17,7 @@ import yaml
from random import randint from random import randint
from appPublic.log import debug, exception, error, info from appPublic.log import debug, exception, error, info
from appPublic.timeUtils import timestampstr from appPublic.timeUtils import timestampstr
from appPublic.dictObject import DictObject
from sqlor.dbpools import get_sor_context from sqlor.dbpools import get_sor_context
from asteval import Interpreter from asteval import Interpreter
@ -367,13 +368,13 @@ where backid=${backid}$
try: try:
f = partial(self.task_success_callback, ne.id) f = partial(self.task_success_callback, ne.id)
ef = partial(self.task_error_callback, ne.id) ef = partial(self.task_error_callback, ne.id)
params = { params = DictObject(**{
prompt: sub_ctx, "prompt": sub_ctx,
callerid: users[0].id, "callerid": users[0].id,
callerorgid: users[0].orgid, "callerorgid": users[0].orgid,
callback:f, "callback":f,
errback: ef "errback": ef
} })
asyncio.create_task(env.run_skillagent, params) asyncio.create_task(env.run_skillagent, params)
except Exception as e: except Exception as e:
await self.task_error_callback(ne.id, str(e)) await self.task_error_callback(ne.id, str(e))