Update app.py

app.py

@@ -291,13 +291,22 @@ def create_agent_executor(llm, tools: List[Tool], tracer: Optional[Any] = None)
     callbacks = []
     if tracer is not None:
         callbacks.append(tracer)
-    executor = AgentExecutor(agent=agent, tools=tools, verbose=True, callbacks=callbacks,max_iterations=10,
+    executor = AgentExecutor(
+    agent=agent,
+    tools=tools,
+    verbose=True,  # إيقاف الطباعة المكثفة — لكن يمكنك تشغيلها أثناء debugging إذا رغبت
+    callbacks=callbacks,
+    max_iterations=10,
     handle_parsing_errors=True,
-    early_stopping_method="force")
+    early_stopping_method="force",
+    return_intermediate_steps=True,   # <<< الأهم — اطلب إعادة intermediate_steps
+    trim_intermediate_steps=-1        # -1 => لا تقص الخطوات قبل الإرجاع (أو حدد عددًا إن أردت الحد)
+     )
     return executor
 
 # -------------------- GAIA Runner --------------------
-class GaiaRunner:
+class GaiaRunner
+
     def __init__(self, agent_executor: AgentExecutor, username: str = "unknown"):
         self.agent = agent_executor
         self.username = username
@@ -332,38 +341,30 @@ class GaiaRunner:
         # ==========================
         # 3️⃣ بناء سجل التفكير الكامل
         # ==========================
-        full_log = []
-        full_log.append(f"Question: {question_text}\n")
-
-        # إذا كان هناك مرفق
+        # بعد الحصول على result
+        if isinstance(result, dict):
+          output = result.get("output") or result.get("text") or str(result)
+          intermediate = result.get("intermediate_steps", [])
+        else:
+          output = getattr(result, "output", str(result))
+          intermediate = []
+# بناء السجل
+        full_log = [f"Question: {question_text}\n"]
         if file_path:
-            full_log.append(f"Attachment: {file_path}\n")
-
-        # إضافة جميع خطوات ReAct الداخلية
-        if "intermediate_steps" in result:
-            for step in result["intermediate_steps"]:
-                try:
-                    action, observation = step
-                    full_log.append(
-                        f"Action: {action.tool}\n"
-                        f"Action Input: {action.tool_input}\n"
-                        f"Observation: {observation}\n"
-                    )
-                except Exception as e:
-                    print(f"[⚠️] Failed to parse intermediate step: {e}")
-
-          # إضافة الإجابة النهائية
-       # output = result.get("output", "")
-        output = result
+          full_log.append(f"Attachment: {file}\n")
+        for step in intermediate:
+          try:
+            action, observation = step
+            full_log.append(
+             f"Thought/Action: {getattr(action, 'log', getattr(action, 'tool', str(action)))}\n"
+             f"Action Input: {getattr(action, 'tool_input', getattr(action, 'input', ''))}\n"
+             f"Observation: {observation}\n"
+              )
+          except Exception as e:
+        # تحصّن أمام صيغ غير متوقعة
+           full_log.append(f"[UNPARSEABLE STEP] {step}\n")
         full_log.append(f"Final Answer: {output}\n")
-
-          # دمج كل السجل في نص واحد
         conversation_log = "\n".join(full_log)
-
-        print("\n🧠 === FULL REACT LOG ===")
-        print(conversation_log)
-        print("==========================")
-
           # ==========================
           # 4️⃣ إرسال السجل الكامل إلى وكيل الإجابة النهائية
           # ==========================
@@ -417,6 +418,7 @@ class GaiaRunner:
         """
         
         response = requests.get(questions_url, timeout=15)
+        print(response)
         if response.status_code == 200:
             questions_data = response.json()
             if questions_data: