Fix the bug of dataflow with ID #31

Author: zhanglongbin

data_server/algo_templates/utils/parse_algo_dslText.py

@@ -1,5 +1,6 @@
 import yaml
 from collections import deque, defaultdict
+from loguru import logger
 
 
 def convert_raw_to_processed(raw_yaml: str) -> str:
@@ -27,6 +28,12 @@ def convert_raw_to_processed(raw_yaml: str) -> str:
         source = edge['source']
         target = edge['target']
 
+        if source not in id_to_node:
+            logger.error(f"edges中引用的source节点 '{source}' 不存在于process中！")
+            raise ValueError(f"edges中引用的source节点 '{source}' 不存在于process中！")
+        if target not in id_to_node:
+            logger.error(f"edges中引用的target节点 '{target}' 不存在于process中！")
+            raise ValueError(f"edges中引用的target节点 '{target}' 不存在于process中！")
 
         adj[source].append(target)
         in_degree[target] += 1

data_server/api/endpoints/algo_templates.py

@@ -133,7 +133,7 @@ async def create_algo_template(
 
     except Exception as e:
         logger.error(f"创建算法模板失败: {e}")
-        return response_fail(msg="创建失败")
+        return response_fail(msg="创建模版失败:" + str(e))
     finally:
         db.close()
 
@@ -179,7 +179,7 @@ async def update_algo_template(
 
     except Exception as e:
         logger.error(f"更新算法模板失败: {e}")
-        return response_fail(msg="更新失败")
+        return response_fail(msg="算法更新失败:" + str(e))
     finally:
         db.close()