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:31:35 +08:00
parent 015765960c
commit 9299d74db5
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
dagflow/dagflow.py
View File

@ -535,6 +535,7 @@ where instance_id=${instance_id}$
return False return False
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=}')
env = Server() env = Server()
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})
@ -547,6 +548,7 @@ where instance_id=${instance_id}$
await sor.U('node_execution', ne) await sor.U('node_execution', ne)
async def task_success_callback(self, ne_id, result): async def task_success_callback(self, ne_id, result):
debug(f'task_error_callback():{ne_id=}, {result=}')
env = ServerEnv() 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})