diff --git a/dagflow/dagflow.py b/dagflow/dagflow.py index b44ff7e..f92a2c5 100644 --- a/dagflow/dagflow.py +++ b/dagflow/dagflow.py @@ -406,7 +406,7 @@ where backid=${backid}$ await sor.C('node_execution', ns) 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): join = node.get('join')