Update app.py

app.py

@@ -50,20 +50,20 @@ async def run_and_submit_all(profile: gr.OAuthProfile | None, progress=gr.Progre
 
     # 2) Parallel-Ausführung mit korrekt gemappten Tasks
     with concurrent.futures.ThreadPoolExecutor(max_workers=MAX_PAR_LLM) as ex:
-        task_map = {
-            asyncio.create_task(run_agent_async(ex, tid, qst)): (tid, qst)
+        # korrekte Reihenfolge: Ergebnisse von gather ↔ Reihenfolge in work
+        tasks = [
+            run_agent_async(ex, tid, qst)      # liefert str-Antwort
             for tid, qst in work
-        }
-        done_total = 0
-        for done in asyncio.as_completed(list(task_map.keys())):  # fix
-            tid, qst = task_map[done]      # garantiert vorhanden
-            answer   = await done
+        ]
+        # gather wartet auf alle, behält Reihenfolge
+        results = await asyncio.gather(*tasks)
+        for idx, answer in enumerate(results):
+            tid, qst = work[idx]
 
             answers.append({"task_id": tid, "submitted_answer": answer})
             logs.append({"Task ID": tid, "Question": qst, "Answer": answer})
 
-            done_total += 1
-            progress(done_total / len(work), desc=f"{done_total}/{len(work)} done")
+            progress((idx + 1) / len(work), desc=f"{idx+1}/{len(work)} done")
 
     # 3) Submit
     submit_url = f"{DEFAULT_API_URL}/submit"