fix: Server is busy (langflow-ai#3878)

9n · Sep 24, 2024 · b34471b · b34471b
1 parent ed53fcd
commit b34471b
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/.dspy_cache/cache.db b/.dspy_cache/cache.db
diff --git 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_vertices(
         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_vertices(
     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: