Added asyncio.new_event_loop

app.py

@@ -6,8 +6,6 @@ from opentelemetry import trace
 from evaluator import Evaluator
 from runner import Runner
 from settings import Settings
-import asyncio
-import nest_asyncio
 import os
 import pandas as pd
 import gradio as gr
@@ -48,11 +46,7 @@ def run_one(profile: gr.OAuthProfile | None) -> pd.DataFrame:
     if not user_logged_in(profile): 
         return LOGIN_MESSAGE, EMPTY_RESULTS_TABLE
     questions = [evaluator.get_one_question()]
-    # Apply nest_asyncio to patch the event loop
-    nest_asyncio.apply()
-    
-    # Now, call run_agent within an event loop
-    results_df = asyncio.run(runner.run_agent(questions))
+    return "Answer one random question...", runner.run_agent(questions)
 
 def run_all(profile: gr.OAuthProfile | None) -> pd.DataFrame:
     if not user_logged_in(profile): 

runner.py

@@ -53,7 +53,11 @@ class Runner():
     def run_agent(self, questions) -> pd.DataFrame:
         """Run the agent(s) async, save answers and return a dataframe"""
         # Assign questions to agents and wait
-        loop = asyncio.get_running_loop()
+        try:
+            loop = asyncio.get_running_loop()
+        except RuntimeError:  # No running loop, create one
+            loop = asyncio.new_event_loop()
+            asyncio.set_event_loop(loop)
 
         def run_tasks_in_thread():
             question_answer_pairs = loop.run_until_complete(