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:49:27 +08:00
parent ab16535041
commit 1a0b00e613
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
dagflow/dagflow.py
View File

@ -539,7 +539,7 @@ where instance_id=${instance_id}$
async def task_error_callback(self, ne_id, errmsg): async def task_error_callback(self, ne_id, errmsg):
debug(f'task_error_callback():{ne_id=}, {errmsg=}') debug(f'task_error_callback():{ne_id=}, {errmsg=}')
env = Server() env = ServerEnv()
async with get_sor_context(env, 'dagflow') as sor: async with get_sor_context(env, 'dagflow') as sor:
recs = await sor.R('node_execution', {'id': ne_id}) recs = await sor.R('node_execution', {'id': ne_id})
if not recs: if not recs: