diff --git a/dagflow/dagflow.py b/dagflow/dagflow.py index ab05fee..1a8d346 100644 --- a/dagflow/dagflow.py +++ b/dagflow/dagflow.py @@ -366,7 +366,7 @@ where backid=${backid}$ await sor.C('node_execution', ns) async def is_ok_to_create_new_node_exe(self, sor, node, edges, inst): - join = node.get('join) + join = node.get('join') if join is None: return True return False