Update app.py

app.py

@@ -4,6 +4,7 @@ import requests
 import inspect
 import pandas as pd
 import time 
+import joblib
 
 # (Keep Constants as is)
 # --- Constants ---
@@ -81,11 +82,16 @@ def run_and_submit_all( profile: gr.OAuthProfile | None):
             continue
         try:
             # We add to counter the token rate limit usage by openai of 30000 TPM
-            time.sleep(5) 
+            time.sleep(10) 
             # end insertion
-            submitted_answer = agent(question_text)
-            answers_payload.append({"task_id": task_id, "submitted_answer": submitted_answer})
-            results_log.append({"Task ID": task_id, "Question": question_text, "Submitted Answer": submitted_answer})
+            try:
+                submitted_answer = agent(question_text)
+                answers_payload.append({"task_id": task_id, "submitted_answer": submitted_answer})
+                results_log.append({"Task ID": task_id, "Question": question_text, "Submitted Answer": submitted_answer})
+            except Exception as e:
+                answers_payload.append({"task_id": task_id, "submitted_answer": str(submitted_answer)})
+                results_log.append({"Task ID": task_id, "Question": question_text, "Submitted Answer": str(submitted_answer)})
+            
         except Exception as e:
              print(f"Error running agent on task {task_id}: {e}")
             # we limit the error message lentgh so we can still submit the other answers
@@ -101,6 +107,10 @@ def run_and_submit_all( profile: gr.OAuthProfile | None):
     status_update = f"Agent finished. Submitting {len(answers_payload)} answers for user '{username}'..."
     print(status_update)
 
+
+    # HERE WE SAVE THE PAYLOAD TO DEBU SUBMISSION
+    joblib.dump(answers_payload,"answer_payload.joblib")
+    
     # 5. Submit
     print(f"Submitting {len(answers_payload)} answers to: {submit_url}")
     try: