diff --git a/dagflow/dagflow.py b/dagflow/dagflow.py index 24b26aa..d941104 100644 --- a/dagflow/dagflow.py +++ b/dagflow/dagflow.py @@ -362,7 +362,7 @@ where backid=${backid}$ for node_id, ctx_ext in nnodes: node = dsl['nodes'][node_id] - x = await self.is_ok_to_create_new_node_exe(sor, node, edges, inst) + x = await self.is_ok_to_create_new_node_exe(sor, node, edge, inst) if x: env = ServerEnv() id = env.uuid()