diff --git a/dagflow/dagflow.py b/dagflow/dagflow.py
index fe6ab90..862c9fd 100644
--- a/dagflow/dagflow.py
+++ b/dagflow/dagflow.py
@@ -274,6 +274,7 @@ where backid=${backid}$
 			))[0]
 
 			dsl = yaml.safe_load(flow_def['dsl'])
+			edges = dsl.get('edges',[])
 			ctx = json.loads(inst['ctx'])
 			sql = "select * from node_execution where instance_id=${instance_id}$ and status != 'completed'"
 			active_nes = await sor.sqlExe(sql, {