Update app.py

app.py

@@ -1,4 +1,5 @@
 import os
+import time
 import requests
 import pandas as pd
 import gradio as gr
@@ -36,24 +37,26 @@ def solve_question(agent, question: str) -> str:
         raw_ans = agent.run(question)
         ans = str(raw_ans).strip()
         
-        # Точечный фильтр от технических утечек трейса
-        if "call_" in ans and "python_interpreter" in ans:
+        # Жесткая защита от утечек трейсов и громоздких объектов
+        if not ans or ans.lower() == "none":
             return "0"
-        if ans.startswith("[{'id':") or ans.startswith("{'id':"):
+        if "call_" in ans or "python_interpreter" in ans or "Error" in ans:
+            return "0"
+        if ans.startswith("[{") or ans.startswith("{'"):
             return "0"
         
-        # Если ответ многострочный, ищем наиболее содержательную строку (не пустую)
+        # Берём последнюю непустую строчку, если ответ многострочный
         if "\n" in ans:
             lines = [line.strip() for line in ans.split("\n") if line.strip()]
             if lines:
-                ans = lines[-1] # Берём последнюю непустую строку
+                ans = lines[-1]
                 
-        # Аккуратная очистка от лишних кавычек и знаков препинания по краям
+        # Чистим кавычки и мусор по краям
         ans = ans.strip(" .\"'`:;")
         
-        # Жёстко обрезаем только явный перебор по длине
-        if len(ans) > 80:
-            ans = ans[:80].strip()
+        # Строгое ограничение длины ответа для сервера оценки (не более 60 символов)
+        if len(ans) > 60:
+            ans = ans[:60].strip()
             
         return ans if ans else "0"
     except Exception as e:
@@ -92,7 +95,7 @@ def run_and_submit_all(profile: gr.OAuthProfile | None):
     results_log = []
     answers_payload = []
 
-    yield "Запуск прогона задач... Соединение защищено.", pd.DataFrame(results_log)
+    yield "Запуск прогона задач... Агент начал выполнение.", pd.DataFrame(results_log)
 
     for item in questions_data:
         task_id = item.get("task_id")
@@ -104,29 +107,46 @@ def run_and_submit_all(profile: gr.OAuthProfile | None):
         answers_payload.append({"task_id": task_id, "submitted_answer": ans})
         results_log.append({"Task ID": task_id, "Question": q, "Submitted Answer": ans})
         
-        # Обновляем табличку на лету без разрыва соединения
+        # Обновляем таблицу в реальном времени через yield
         yield f"Выполнено задач: {len(results_log)} из {len(questions_data)}...", pd.DataFrame(results_log)
 
-    yield "Все задачи обработаны. Отправка пакета на сервер оценки...", pd.DataFrame(results_log)
-
-    try:
-        sub_res = requests.post(
-            f"{DEFAULT_API_URL}/submit",
-            json={"username": username, "agent_code": agent_code, "answers": answers_payload},
-            timeout=180
-        )
-        sub_res.raise_for_status()
-        data = sub_res.json()
-        
-        status = (
-            f"Submission Successful!\n"
-            f"User: {data.get('username')}\n"
-            f"Overall Score: {data.get('score', 'N/A')}%\n"
-            f"Message: {data.get('message', '')}"
-        )
-        yield status, pd.DataFrame(results_log)
-    except Exception as e:
-        yield f"Submission status: {e}", pd.DataFrame(results_log)
+    yield "Все задачи решены. Отправка пакета на сервер оценки (с защитой от 500 ошибки)...", pd.DataFrame(results_log)
+
+    # Попытка отправки с ретраями на случай падения бэкенда курса
+    sub_res = None
+    success = False
+    for attempt in range(3):
+        try:
+            sub_res = requests.post(
+                f"{DEFAULT_API_URL}/submit",
+                json={"username": username, "agent_code": agent_code, "answers": answers_payload},
+                timeout=180
+            )
+            if sub_res.status_code == 200:
+                success = True
+                break
+            else:
+                time.sleep(3)
+        except Exception:
+            time.sleep(3)
+
+    if success and sub_res:
+        try:
+            data = sub_res.json()
+            status = (
+                f"Submission Successful!\n"
+                f"User: {data.get('username')}\n"
+                f"Overall Score: {data.get('score', 'N/A')}%\n"
+                f"Message: {data.get('message', '')}"
+            )
+            yield status, pd.DataFrame(results_log)
+            return
+        except Exception:
+            pass
+
+    # Если даже после ретраев сервер вернул ошибку
+    err_text = sub_res.text if sub_res else "Connection timeout/error"
+    yield f"Submission status: 500 Server Error (Сервер курса перегружен). Попробуй нажать кнопку повторно через пару минут.\nDetails: {err_text}", pd.DataFrame(results_log)
 
 with gr.Blocks() as demo:
     gr.Markdown("# GAIA Smart Agent Runner")