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:12:09 +08:00
parent 21acaca857
commit 6538efb6ac
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

@ -527,7 +527,7 @@ where instance_id=${instance_id}$
return True return True
if some <= float(len(trecs))/float(len(recs)): if some <= float(len(trecs))/float(len(recs)):
return True return True
debug(f'部分成功模式：{some=},已完成：{len(trecs)=}，总数:{len(recs)=}' debug(f'部分成功模式：{some=},已完成：{len(trecs)=}，总数:{len(recs)=}')
return False return False
async def task_error_callback(self, ne_id, errmsg): async def task_error_callback(self, ne_id, errmsg):