diff --git a/src/backend/base/langflow/processing/load.py b/src/backend/base/langflow/processing/load.py
index a2be59d95..f6781fe2d 100644
--- a/src/backend/base/langflow/processing/load.py
+++ b/src/backend/base/langflow/processing/load.py
@@ -3,6 +3,8 @@ from pathlib import Path
 from typing import List, Optional, Union
 
 from dotenv import load_dotenv
+from loguru import logger
+
 from langflow.graph import Graph
 from langflow.graph.schema import RunOutputs
 from langflow.processing.process import process_tweaks, run_graph
@@ -101,6 +103,12 @@ def run_flow_from_json(
         List[RunOutputs]: A list of RunOutputs objects representing the results of running the flow.
     """
     # Set all streaming to false
+    try:
+        import nest_asyncio
+
+        nest_asyncio.apply()
+    except Exception as e:
+        logger.warning(f"Could not apply nest_asyncio: {e}")
     if tweaks is None:
         tweaks = {}
     tweaks["stream"] = False
diff --git a/src/backend/base/langflow/processing/process.py b/src/backend/base/langflow/processing/process.py
index b49b20748..2d8356159 100644
--- a/src/backend/base/langflow/processing/process.py
+++ b/src/backend/base/langflow/processing/process.py
@@ -1,5 +1,6 @@
 from typing import TYPE_CHECKING, Any, Dict, List, Optional, Tuple, Union
 
+
 from langchain.agents import AgentExecutor
 from langchain.schema import AgentAction
 from loguru import logger
@@ -13,6 +14,7 @@ from langflow.schema.graph import InputValue, Tweaks
 from langflow.schema.schema import INPUT_FIELD_NAME
 from langflow.services.session.service import SessionService
 
+
 if TYPE_CHECKING:
     from langflow.api.v1.schemas import InputValueRequest