diff --git a/apps/manager/appcenter.py b/apps/manager/appcenter.py
index 9f0ae664e528c8f6a324e5ee89cdde36e6d29602..9631ac9aee9b82ad9057dc9af709828626eaf66a 100644
--- a/apps/manager/appcenter.py
+++ b/apps/manager/appcenter.py
@@ -97,7 +97,6 @@ class AppCenterManager:
         :return: 应用列表, 总应用数
         """
         try:
-            # 搜索条件
             if search_type == SearchType.AUTHOR:
                 if keyword not in user_sub:
                     return [], 0
diff --git a/apps/manager/flow.py b/apps/manager/flow.py
index 75229ac88ede9fd57110e3f75e5140f3b2518f1e..3cfe2d90791e810b9991d32533c5449dc8e54f83 100644
--- a/apps/manager/flow.py
+++ b/apps/manager/flow.py
@@ -259,11 +259,11 @@ class FlowManager:
                 debug=flow_config.debug,
             )
             for node_id, node_config in flow_config.steps.items():
+                input_parameters = node_config.params
                 if node_config.node not in ("Empty"):
-                    input_parameters = node_config.params
                     _, output_parameters = await NodeManager.get_node_params(node_config.node)
                 else:
-                    input_parameters, output_parameters = {}, {}
+                    output_parameters = {}
                 parameters = {
                     "input_parameters": input_parameters,
                     "output_parameters": output_parameters,
diff --git a/apps/service/flow.py b/apps/service/flow.py
index 3f4e05735c00ee42114980ca65a11942da4e5b06..1fe71d6b6c7b97120e5b1fa48663ea001db79ffb 100644
--- a/apps/service/flow.py
+++ b/apps/service/flow.py
@@ -39,8 +39,16 @@ class FlowService:
         """移除流程图中的多余结构"""
         node_branch_map = {}
         branch_illegal_chars = "."
-
         for node in flow_item.nodes:
+            from apps.scheduler.pool.pool import Pool
+            from pydantic import BaseModel
+            try:
+                call_class: type[BaseModel] = await Pool().get_call(node.call_id)
+            except Exception as e:
+                logger.error(f"[FlowService] 获取步骤的call_id失败{node.call_id}")
+                raise Exception(e)
+            if not call_class:
+                node.node = 'Empty'
             node_branch_map[node.step_id] = set()
             if node.call_id == NodeType.CHOICE.value:
                 node.parameters = node.parameters["input_parameters"]