diff --git a/src/backend/base/langflow/utils/async_helpers.py b/src/backend/base/langflow/utils/async_helpers.py
new file mode 100644
index 000000000..25ce54451
--- /dev/null
+++ b/src/backend/base/langflow/utils/async_helpers.py
@@ -0,0 +1,35 @@
+import asyncio
+import threading
+
+
+def run_until_complete(coro):
+    try:
+        loop = asyncio.get_event_loop()
+        if loop.is_running():
+            # Run the coroutine in a separate event loop in a new thread
+            return run_in_thread(coro)
+        else:
+            return loop.run_until_complete(coro)
+    except RuntimeError:
+        # If there's no event loop, create a new one and run the coroutine
+        return asyncio.run(coro)
+
+
+def run_in_thread(coro):
+    result = None
+    exception = None
+
+    def target():
+        nonlocal result, exception
+        try:
+            result = asyncio.run(coro)
+        except Exception as e:
+            exception = e
+
+    thread = threading.Thread(target=target)
+    thread.start()
+    thread.join()
+
+    if exception:
+        raise exception
+    return result