Merge branch 'feat/agent-catalog' into feat/agent-catalog-policy

Author: erichare

src/backend/base/langflow/agentic/services/flow_executor.py

@@ -12,7 +12,7 @@
 from fastapi import HTTPException
 from lfx.cli.script_loader import extract_structured_result
 from lfx.events.event_manager import EventManager, create_default_event_manager
-from lfx.execution import get_default_coordinator
+from lfx.execution import aget_default_coordinator
 from lfx.log.logger import logger
 from lfx.schema.schema import InputValueRequest
 from lfx.utils.flow_validation import CustomComponentValidationError
@@ -60,11 +60,9 @@ async def _run_graph_with_events(
         graph.prepare()
         inputs = InputValueRequest(input_value=input_value) if input_value else None
 
+        coordinator = await aget_default_coordinator()
         results = [
-            payload
-            async for payload in get_default_coordinator().stream(
-                graph, initial_inputs=inputs, event_manager=event_manager
-            )
+            payload async for payload in coordinator.stream(graph, initial_inputs=inputs, event_manager=event_manager)
         ]
         execution_result.result = extract_structured_result(results)
     except Exception as e:  # noqa: BLE001
@@ -137,7 +135,8 @@ async def execute_flow_file(
         graph.prepare()
         inputs = InputValueRequest(input_value=input_value) if input_value else None
 
-        results = [payload async for payload in get_default_coordinator().stream(graph, initial_inputs=inputs)]
+        coordinator = await aget_default_coordinator()
+        results = [payload async for payload in coordinator.stream(graph, initial_inputs=inputs)]
         flow_result = extract_structured_result(results)
     except HTTPException:
         raise