From 1730e233dfd15e7c4b269ae9337a35703da66c9c Mon Sep 17 00:00:00 2001
From: yumoqing <yumoqing@gmail.com>
Date: Mon, 16 Mar 2026 16:29:15 +0800
Subject: [PATCH] bugfix

---
 dagflow/dagflow.py       | 2 --
 dagflow/init.py          | 2 +-
 wwwroot/manual_step.dspy | 2 ++
 3 files changed, 3 insertions(+), 3 deletions(-)
 create mode 100644 wwwroot/manual_step.dspy

diff --git a/dagflow/dagflow.py b/dagflow/dagflow.py
index 2d29f0c..05ceb96 100644
--- a/dagflow/dagflow.py
+++ b/dagflow/dagflow.py
@@ -240,8 +240,6 @@ where backid=${backid}$
 
 			dsl = yaml.safe_load(flow_def['dsl'])
 			ctx = json.loads(inst['ctx'])
-			active = set(json.loads(inst['active_nodes']) or [dsl['start']])
-			next_nodes = set()
 			sql = "select * from node_execution where instance_id=${instance_id}$ and status != 'completed'"
 			active_nes = await sor.sqlExe(sql, {
 				'instance_id': inst.id
diff --git a/dagflow/init.py b/dagflow/init.py
index 0e6cbf5..9795923 100644
--- a/dagflow/init.py
+++ b/dagflow/init.py
@@ -31,7 +31,7 @@ def load_dagflow():
 		flow_engines.append(e)
 
 	f = partial(dagbacktask, flow_engines)
-	add_cleanupctx(f)
+	# add_cleanupctx(f)
 	env = ServerEnv()
 	env.flow_engines = flow_engines
 	env.add_new_workflow = add_new_workflow
diff --git a/wwwroot/manual_step.dspy b/wwwroot/manual_step.dspy
new file mode 100644
index 0000000..87816f5
--- /dev/null
+++ b/wwwroot/manual_step.dspy
@@ -0,0 +1,2 @@
+await flow_engines[0].bgtask()
+return 'OK'