fix style check

api/core/datasource/utils/parser.py

@@ -101,7 +101,7 @@ class ApiBasedToolSchemaParser:
 
                     # parse body parameters
                     if "schema" in interface["operation"]["requestBody"]["content"][content_type]:  # pyright: ignore[reportIndexIssue, reportPossiblyUnboundVariable]
-                        body_schema = interface["operation"]["requestBody"]["content"][content_type]["schema"]
+                        body_schema = interface["operation"]["requestBody"]["content"][content_type]["schema"]  # pyright: ignore[reportIndexIssue, reportPossiblyUnboundVariable]
                         required = body_schema.get("required", [])
                         properties = body_schema.get("properties", {})
                         for name, property in properties.items():

api/core/workflow/errors.py

@@ -6,3 +6,11 @@ class WorkflowNodeRunFailedError(Exception):
         self._node = node
         self._error = err_msg
         super().__init__(f"Node {node.title} run failed: {err_msg}")
+
+    @property
+    def node(self) -> Node:
+        return self._node
+
+    @property
+    def error(self) -> str:
+        return self._error

api/services/rag_pipeline/rag_pipeline.py

@@ -387,7 +387,9 @@ class RagPipelineService:
 
         return default_block_configs
 
-    def get_default_block_config(self, node_type: str, filters: Optional[dict] = None) -> Optional[dict]:
+    def get_default_block_config(
+        self, node_type: str, filters: Optional[dict] = None
+    ) -> Optional[Mapping[str, object]]:
         """
         Get default config of node.
         :param node_type: node type

api/services/workflow_service.py

@@ -811,10 +811,10 @@ class WorkflowService:
             error = node_run_result.error if not run_succeeded else None
             return node, node_run_result, run_succeeded, error
         except WorkflowNodeRunFailedError as e:
-            node = e._node
+            node = e.node
             run_succeeded = False
             node_run_result = None
-            error = e._error
+            error = e.error
             return node, node_run_result, run_succeeded, error
 
     def _apply_error_strategy(self, node: Node, node_run_result: NodeRunResult) -> NodeRunResult: