Merge branch 'flow2.0-operators' into chore/update-api

dbgpt/core/awel/flow/flow_factory.py

@@ -609,6 +609,11 @@ def build(self, flow_panel: FlowPanel) -> DAG:
                 key_to_resource_nodes[key] = node
                 key_to_resource[key] = node.data
 
+        if not key_to_operator_nodes and not key_to_resource_nodes:
+            raise FlowMetadataException(
+                "No operator or resource nodes found in the flow."
+            )
+
         for edge_index, edge in enumerate(flow_data.edges):
             source_key = edge.source
             target_key = edge.target

dbgpt/serve/flow/api/endpoints.py

@@ -158,7 +158,10 @@ async def update(
         ServerResponse: The response
     """
     try:
-        return Result.succ(service.update_flow(request))
+        res = await blocking_func_to_async(
+            global_system_app, service.update_flow, request
+        )
+        return Result.succ(res)
     except Exception as e:
         return Result.failed(msg=str(e))