Update app.py

app.py

@@ -90,11 +90,11 @@ async def process_question(agent, question_text: str, task_id: str, results_log:
             if e.status == 429:
                 print(f"Rate limit hit for task {task_id}. Retrying after delay...")
                 retry_delay *= 2  # Exponential backoff
-                retry_delay += random.uniform(0, 5)  # Jitter
+#                retry_delay += random.uniform(0, 5)  # Jitter
                 print(f"Retry #{attempt+1} in {retry_delay:.1f}s")
                 await asyncio.sleep(retry_delay)
                 while not token_bucket.consume(1):
-                    await asyncio.sleep(60 / RATE_LIMIT)
+                    await asyncio.sleep(60)
                 try:
                     submitted_answer = await agent(question_text)
                     results_log.append({"Task ID": task_id, "Question": question_text, "Submitted Answer": submitted_answer})
@@ -160,7 +160,8 @@ async def run_and_submit_all(profile: gr.OAuthProfile | None):
                 result = await process_question(agent, item["question"], item["task_id"], results_log)
                 if result:
                     answers_payload.append(result)
-
+            await asyncio.sleep(30)
+            
         if not answers_payload:
             print("Agent did not produce any answers to submit.")
             return "Agent did not produce any answers to submit.", pd.DataFrame(results_log)