Update app.py

app.py

@@ -26,6 +26,10 @@ from langchain.agents import create_react_agent, AgentExecutor
 from datasets import load_dataset
 from huggingface_hub import login
 import os
+import threading
+
+# قفل عام لحماية الوصول إلى LLM/Agent داخل الخيوط
+llama_lock = threading.Lock()
 
 # تحقق من وجود توكن في متغير البيئة
 HF_TOKEN = os.getenv("HF_TOKEN")
@@ -241,25 +245,32 @@ class GaiaRunner:
         self.username = username
 
     def run_on_question(self, question_text: str, file: Optional[str] = None) -> str:
-        import time
-        start = time.time()
-        
-        prompt = SYSTEM_INSTRUCTIONS + "\n\n" + question_text
-        try:
+    import time
+    start = time.time()
+    
+    prompt = SYSTEM_INSTRUCTIONS + "\n\n" + question_text
+    try:
+        # حماية استدعاء الـ agent (langchain / llama-cpp) من الوصول المتوازي
+        with llama_lock:
             result = self.agent.invoke({"input": prompt})
-            if isinstance(result, dict):
-                output = result.get("output") or result.get("text") or str(result)
-            else:
-                output = getattr(result, "output", str(result))
-        except Exception as e:
-            logger.exception("Agent execution failed")
-            output = f"AGENT_ERROR: {e}"
+        if isinstance(result, dict):
+            output = result.get("output") or result.get("text") or str(result)
+        else:
+            output = getattr(result, "output", str(result))
+    except Exception as e:
+        logger.exception("Agent execution failed")
+        output = f"AGENT_ERROR: {e}"
 
+    try:
         final_out = final_client.predict_text(output)
-        end = time.time()
-        logger.info(f"⏱️ Time for question: {end - start:.2f} sec")
+    except Exception as e:
+        logger.exception("Final client failed")
+        final_out = f"FINAL_AGENT_ERROR: {e}"
+
+    end = time.time()
+    logger.info(f"⏱️ Time for question: {end - start:.2f} sec")
 
-        return final_out
+    return final_out
 
     def run_all_and_submit(self) -> Dict[str, Any]:
         questions_url =f"{GAIA_API_BASE}/questions"
@@ -445,5 +456,4 @@ def gradio_interface():
 
 if __name__ == "__main__":
     demo = gradio_interface()
-    demo.launch(show_error=True, share=False)
-    
+    demo.launch(server_name="0.0.0.0", server_port=int(os.getenv("PORT", 7860)), show_error=True, share=False)