Update app.py

app.py

@@ -1,9 +1,13 @@
 import os
 import streamlit as st
-import asyncio
 import nest_asyncio
 nest_asyncio.apply()  # allow asyncio in Streamlit :contentReference[oaicite:3]{index=3}
 
+import asyncio
+# Create (or get) the running loop for all Workflow calls
+loop = asyncio.new_event_loop()
+asyncio.set_event_loop(loop)
+
 # ─── LlamaIndex & Parser Imports ────────────────────────────────
 from llama_index.core import StorageContext, load_index_from_storage
 from llama_index.llms.openai import OpenAI
@@ -95,7 +99,8 @@ if "workflow" not in st.session_state:
 # 3) User input
 user_input = st.text_input("Ask a question about the document:")
 if user_input:
-    stop_evt: StopEvent = asyncio.run(
+    # Drive the async workflow.run() on our loop
+    stop_evt: StopEvent = loop.run_until_complete(
         st.session_state.workflow.run(
             index_dir=INDEX_DIR,
             query=user_input,