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 11:33:05 +08:00
parent 0f79e07c12
commit df638f3941
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

@ -406,7 +406,7 @@ where backid=${backid}$
await sor.C('node_execution', ns) await sor.C('node_execution', ns)
else: else:
debug(f'{node=}, {edge=}, {inst=}is_ok_to_create_new_node_exe() 返回了{x}' debug(f'{node=}, {edge=}, {inst=}is_ok_to_create_new_node_exe() 返回了{x}')
async def is_ok_to_create_new_node_exe(self, sor, node, edges, inst): async def is_ok_to_create_new_node_exe(self, sor, node, edges, inst):
join = node.get('join') join = node.get('join')