From 1c11a995d75e843cf21bcd5dd2382914ebf66305 Mon Sep 17 00:00:00 2001 From: yumoqing Date: Mon, 16 Mar 2026 16:36:14 +0800 Subject: [PATCH] bugfix --- dagflow/dagflow.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/dagflow/dagflow.py b/dagflow/dagflow.py index 677ca4b..0832c35 100644 --- a/dagflow/dagflow.py +++ b/dagflow/dagflow.py @@ -260,7 +260,7 @@ where backid=${backid}$ elif ntype == 'subflow': await self.try_start_subflow(sor, inst, ne, node) elif ntype == 'start': - await self.node_transfer(sor, inst, ne, node, flow_def) + await self.node_transfer(sor, dsl, inst, ne, node, flow_def) await sor.U('node_execution', { 'id': ne.id, 'status': 'completed' @@ -278,7 +278,7 @@ where backid=${backid}$ }) break; elif status in ['done', 'cancelled', 'failed']: - await self.node_transfer(sor, inst, ne, node, flow_def) + await self.node_transfer(sor, dsl, inst, ne, node, flow_def) await sor.U('node_execution', { 'id': ne.id, 'status': 'completed'