Add async logic

app.py

@@ -70,7 +70,7 @@ class BasicAgent:
         return final_answer
 
 
-def run_and_submit_all(profile: gr.OAuthProfile | None):
+async def run_and_submit_all(profile: gr.OAuthProfile | None):
     """
     Fetches all questions, runs the BasicAgent on them, submits all answers,
     and displays the results.
@@ -124,7 +124,7 @@ def run_and_submit_all(profile: gr.OAuthProfile | None):
     results_log = []
     answers_payload = []
     print(f"Running agent on {len(questions_data)} questions...")
-    for item in questions_data:
+    async for item in questions_data:
         task_id = item.get("task_id")
         question_text = item.get("question")
         file_name = item.get("file_name")
@@ -132,7 +132,7 @@ def run_and_submit_all(profile: gr.OAuthProfile | None):
             print(f"Skipping item with missing task_id or question: {item}")
             continue
         try:
-            submitted_answer = agent(question_text, task_id, file_name)
+            submitted_answer = await agent(question_text, task_id, file_name)
             answers_payload.append(
                 {"task_id": task_id, "submitted_answer": submitted_answer}
             )

requirements.txt

@@ -9,4 +9,5 @@ Pillow
 yt-dlp
 html2text
 llama-index-utils-workflow
-llama-index-llms-huggingface-api
+llama-index-llms-huggingface-api
+asyncio