Update app.py

app.py

@@ -298,17 +298,32 @@ def initialize_agent():
 # --- Hauptfunktion run_and_submit_all (weitgehend unverändert) ---
 # Die Logik zum Holen der Fragen, Iterieren, Prompt erstellen, Agent aufrufen,
 # Antworten sammeln und Submitten bleibt gleich. Nur die Initialisierung oben ist anders.
+# --- Hauptfunktion run_and_submit_all (MIT DEBUG-PRINT) ---
 def run_and_submit_all( profile: gr.OAuthProfile | None, progress=gr.Progress(track_tqdm=True)):
     """
     Fetches all questions, runs the smolagents CodeAgent on them, submits all answers,
     and displays the results. Includes Gradio progress tracking.
     """
+    # +++ DEBUGGING PRINT +++
+    print(f"--- Entering run_and_submit_all ---")
+    print(f"Received profile object: {profile}")
+    if profile:
+        print(f"Profile username: {getattr(profile, 'username', 'N/A')}")
+        print(f"Profile details: {vars(profile) if profile else 'N/A'}") # Zeige alle Attribute des Profils
+    else:
+        print("Profile object is None.")
+    # +++ END DEBUGGING PRINT +++
+
     space_id = os.getenv("SPACE_ID")
+
+    # *** HIER die eigentliche Prüfung ***
     if not profile:
-        print("User not logged in.")
+        print("Condition 'if not profile:' is TRUE. Returning login message.")
         return "Please Login to Hugging Face with the button.", None
-    username = f"{profile.username}"
-    print(f"User logged in: {username}")
+
+    # Ab hier sollte der Code nur laufen, wenn profile NICHT None ist
+    username = f"{profile.username}" # Jetzt sicher, da profile nicht None ist
+    print(f"Proceeding with run for user: {username}")
 
     api_url = DEFAULT_API_URL
     questions_url = f"{api_url}/questions"
@@ -388,17 +403,22 @@ Let's begin the thinking process for Task {task_id}.
                  submitted_answer = cleaned_response if cleaned_response else "Error: Agent returned empty response after cleaning."
             else:
                  submitted_answer = "Error: Agent returned an empty or None response."
-            print(f"Task {task_id} completed. Submitted Answer: '{submitted_answer}'")
+            # Kurze Pause nach jedem Agentenlauf, um Rate Limits etc. zu vermeiden (optional)
+            # time.sleep(0.5)
 
         except Exception as e:
              error_msg = f"AGENT_RUN_ERROR on task {task_id} ({type(e).__name__}): {e}"
              print(error_msg)
              # Hier könnte man spezifischere Fehler von HfApiModel abfangen, falls bekannt
              submitted_answer = f"ERROR: Agent failed ({type(e).__name__})"
+             # Bei API Fehlern ggf. kurz warten und erneut versuchen (nicht implementiert)
 
         finally:
             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})
+            # Logge die konkrete Antwort, die hinzugefügt wird
+            print(f"Task {task_id} logged. Answer added: '{submitted_answer[:100]}...'")
+
 
     end_time = datetime.now(); duration = end_time - start_time
     print(f"Agent processing finished in {duration}.")
@@ -410,12 +430,15 @@ Let's begin the thinking process for Task {task_id}.
         return "Agent did not produce any answers to submit.", pd.DataFrame(results_log)
     submission_data = {"username": username.strip(), "agent_code": agent_code, "answers": answers_payload}
     print(f"Submitting {len(answers_payload)} answers for user '{username}'...")
+    # Debug: Zeige die ersten paar Antworten vor dem Senden
+    print(f"Sample answers payload: {answers_payload[:2]}")
+
 
     # 5. Submit (unverändert)
     final_status = "Submission attempt finished."
     results_df = pd.DataFrame(results_log)
     try:
-        response = requests.post(submit_url, json=submission_data, timeout=120)
+        response = requests.post(submit_url, json=submission_data, timeout=180) # Längeres Timeout für Submit
         response.raise_for_status()
         result_data = response.json()
         final_status = (f"Submission Successful!\nUser: {result_data.get('username')}\n"
@@ -423,17 +446,23 @@ Let's begin the thinking process for Task {task_id}.
                        f"Message: {result_data.get('message', 'No message received.')}")
         print("Submission successful.")
     except requests.exceptions.HTTPError as e:
-        error_detail = f"... {e.response.status_code}." # Gekürzte Fehlermeldung für Code-Lesbarkeit
-        # (Vollständige Fehlerbehandlung wie zuvor)
+        error_detail = f"Server responded with status {e.response.status_code}."
         try:
             error_json = e.response.json(); api_error = error_json.get('detail', e.response.text)
-            if isinstance(api_error, list) and len(api_error) > 0: error_detail += f" Detail: {api_error[0].get('msg', str(api_error))}"
-            else: error_detail += f" Detail: {str(api_error)}"
-        except: error_detail += f" Response: {e.response.text[:200]}"
+            # Verbesserte Fehleranzeige für Validierungsfehler
+            if isinstance(api_error, list) and api_error and isinstance(api_error[0], dict):
+                 error_msgs = [f"{err.get('loc', ['unknown'])[-1]}: {err.get('msg', '')}" for err in api_error]
+                 error_detail += f" Details: {'; '.join(error_msgs)}"
+            elif isinstance(api_error, str):
+                 error_detail += f" Detail: {api_error[:500]}" # Begrenze Länge
+            else:
+                 error_detail += f" Detail: {str(api_error)[:500]}"
+        except requests.exceptions.JSONDecodeError:
+            error_detail += f" Raw Response: {e.response.text[:500]}" # Begrenze Länge
         final_status = f"Submission Failed: {error_detail}"; print(final_status)
-    except requests.exceptions.Timeout: final_status = "Submission Failed: Timeout."; print(final_status)
+    except requests.exceptions.Timeout: final_status = "Submission Failed: The request timed out after 180 seconds."; print(final_status)
     except requests.exceptions.RequestException as e: final_status = f"Submission Failed: Network error - {e}"; print(final_status)
-    except Exception as e: final_status = f"Submission Failed: Unexpected error ({type(e).__name__}): {e}"; print(final_status)
+    except Exception as e: final_status = f"Submission Failed: Unexpected error during submission ({type(e).__name__}): {e}"; print(final_status)
     finally: cleanup_temp_files()
 
     progress(1, desc="Done.")