Update app.py

app.py

@@ -6,6 +6,7 @@
 import os
 import json
 import requests
+import time
 from typing import Dict, Any, List
 
 # Импортируем агента
@@ -119,41 +120,48 @@ class GAIASubmitter:
             print("Using cached submission response")
             return self.cache[cache_key]
         
-        # Отправляем запрос на сервер
-        print(f"Submitting answers to {API_URL}...")
-        try:
-            response = requests.post(API_URL, json=submission_data)
-            
-            # Сохраняем ответ для отладки
-            with open("response_content.txt", 'w', encoding='utf-8') as f:
-                f.write(response.text)
-                print("Response content saved to response_content.txt")
-            
-            # Проверяем статус ответа
-            if response.status_code == 200:
-                print("Submission successful!")
-                result = response.json()
-                
-                # Сохраняем результат для отладки
-                with open("results_response.txt", 'w', encoding='utf-8') as f:
-                    json.dump(result, f, ensure_ascii=False, indent=2)
-                    print("Results saved to results_response.txt")
+        # Отправляем запрос на сервер с повторными попытками
+        max_retries = 3
+        for attempt in range(max_retries):
+            try:
+                print(f"Submitting answers to {API_URL} (attempt {attempt+1}/{max_retries})...")
+                response = requests.post(API_URL, json=submission_data, timeout=10)
                 
-                # Сохраняем в кэш
-                if self.use_cache:
-                    self.cache[cache_key] = result
-                    self._save_cache()
+                # Сохраняем ответ для отладки
+                with open("response_content.txt", 'w', encoding='utf-8') as f:
+                    f.write(response.text)
+                    print("Response content saved to response_content.txt")
                 
-                return result
-            else:
-                error_msg = f"Submission failed with status code {response.status_code}: {response.text}"
+                # Проверяем статус ответа
+                if response.status_code == 200:
+                    print("Submission successful!")
+                    result = response.json()
+                    
+                    # Сохраняем результат для отладки
+                    with open("results_response.txt", 'w', encoding='utf-8') as f:
+                        json.dump(result, f, ensure_ascii=False, indent=2)
+                        print("Results saved to results_response.txt")
+                    
+                    # Сохраняем в кэш
+                    if self.use_cache:
+                        self.cache[cache_key] = result
+                        self._save_cache()
+                    
+                    return result
+                else:
+                    error_msg = f"HTTP error {response.status_code}: {response.text}"
+                    print(error_msg)
+                    
+            except requests.exceptions.RequestException as e:
+                error_msg = f"Network error: {str(e)}"
                 print(error_msg)
-                return {"error": error_msg}
-                
-        except Exception as e:
-            error_msg = f"Error during submission: {e}"
-            print(error_msg)
-            return {"error": error_msg}
+            
+            # Экспоненциальная задержка перед следующей попыткой
+            delay = 2 ** attempt
+            print(f"Retrying in {delay} seconds...")
+            time.sleep(delay)
+        
+        return {"error": f"All {max_retries} attempts failed"}
 
 def main():
     """
@@ -208,4 +216,4 @@ def main():
                 print(f"- {task_id}: {detail}")
 
 if __name__ == "__main__":
-    main()
+    main()