make it async

app.py

@@ -68,15 +68,15 @@ class BasicAgent:
         except Exception as e:
             print(f"Error intialising agent: {e}")
 
-    def __call__(self, input_text: str):
+    async def __call__(self, input_text: str):
         """Make the agent callable directly."""
         return self.agent.run(input_text)
 
-    def run(self, input_text: str):
+    async def run(self, input_text: str):
         """Alternative explicit method."""
         return self.agent.run(input_text)
     
-    def stream(self, input_text: str):
+    async def stream(self, input_text: str):
         # Use `.stream_response()` for a streaming output
         for chunk in self.agent.stream_response(input_text):
             yield chunk.delta
@@ -143,7 +143,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)
+            submitted_answer = await agent(question_text)
             answers_payload.append(
                 {"task_id": task_id, "submitted_answer": submitted_answer}
             )