From a4ae2b52a0d31be9295ebfa905ea0464806ae0df Mon Sep 17 00:00:00 2001
From: Jan Cheng <9n@users.noreply.github.com>
Date: Tue, 24 Sep 2024 21:49:30 +0800
Subject: [PATCH] fix: Server is busy (#3878) (#3895)

---
 src/backend/base/langflow/api/v1/chat.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/backend/base/langflow/api/v1/chat.py b/src/backend/base/langflow/api/v1/chat.py
index 5990807f3..b0f7d477f 100644
--- a/src/backend/base/langflow/api/v1/chat.py
+++ b/src/backend/base/langflow/api/v1/chat.py
@@ -324,7 +324,7 @@ async def build_flow(
         client_consumed_queue: asyncio.Queue,
         event_manager: "EventManager",
     ) -> None:
-        build_task = asyncio.create_task(await asyncio.to_thread(_build_vertex, vertex_id, graph, event_manager))
+        build_task = asyncio.create_task(asyncio.to_thread(asyncio.run, _build_vertex(vertex_id, graph, event_manager)))
         try:
             await build_task
         except asyncio.CancelledError as exc:
@@ -359,7 +359,7 @@ async def build_flow(
     async def event_generator(event_manager: EventManager, client_consumed_queue: asyncio.Queue) -> None:
         if not data:
             # using another thread since the DB query is I/O bound
-            vertices_task = asyncio.create_task(await asyncio.to_thread(build_graph_and_get_order))
+            vertices_task = asyncio.create_task(asyncio.to_thread(asyncio.run, build_graph_and_get_order()))
             try:
                 await vertices_task
             except asyncio.CancelledError: