jjj

my_tools.py

@@ -224,28 +224,44 @@ def _pd_safe_import():
 
 
 def analyze_markdown_table(table_md: str, question: str) -> str:
-    """Check commutativity or return CSV. Requires pandas lazily."""
     try:
         pd = _pd_safe_import()
-        lines = [l for l in table_md.strip().splitlines() if l.strip() and not l.lstrip().startswith("|---")]
-        rows = [[c.strip() for c in l.strip().strip("|").split("|")] for l in lines]
+
+        # — 1️⃣  Parseo seguro del markdown —
+        clean = [
+            ln for ln in table_md.strip().splitlines()
+            if ln.strip() and not ln.lstrip().startswith("|---")
+        ]
+        rows = [ [c.strip() for c in ln.strip("|").split("|")] for ln in clean ]
         if len(rows) < 2:
             return "Error analyze_table: empty or malformed markdown table"
+
         df = pd.DataFrame(rows[1:], columns=rows[0])
+
+        # — 2️⃣  ¿Nos piden conmutatividad? —
         if "conmut" in question.lower():
-            cols = df.columns.tolist()[1:]
-            offenders = {
-                col
-                for x in cols
-                for y in cols
-                if df.loc[df[rows[0][0]] == x, y].iat[0] != df.loc[df[rows[0][0]] == y, x].iat[0]
-            }
+            offenders: set[str] = set()
+            header = df.columns[0]        # nombre de la columna/índice
+
+            cols = df.columns[1:]         # solo las etiquetas
+            for x in cols:
+                for y in cols:
+                    try:
+                        val_xy = df.loc[df[header] == x, y].iat[0]
+                        val_yx = df.loc[df[header] == y, x].iat[0]
+                        if val_xy != val_yx:
+                            offenders.update([x, y])
+                    except (IndexError, KeyError):
+                        continue
             return ", ".join(sorted(offenders)) or "Conmutativa"
+
+        # — 3️⃣  Si no, devolvemos CSV —
         return df.to_csv(index=False)
     except Exception as exc:
         return f"Error analyze_markdown_table: {exc}"
 
 
+
 def execute_code(code: str) -> str:
     """Runs arbitrary **short** python code in a sandboxed subprocess."""
     try:
@@ -363,18 +379,23 @@ def scrape_wiki_table(page_title: str, section: str | None = None, table_index:
 # --- generic URL text scraper ---
 
 def scrape_url_text(url: str) -> str:
-    """Downloads a webpage and returns cleaned visible text (trimmed to 8k chars)."""
+    """Descarga página y devuelve texto visible (trim-8k)."""
     try:
-        html = requests.get(url, headers=HEADERS, timeout=20).text
-        soup = BeautifulSoup(html, "html.parser")
+        resp = requests.get(url, headers=HEADERS, timeout=20)
+        if "Just a moment" in resp.text and "cloudflare" in resp.text.lower():
+            return "Error scrape_url_text: Cloudflare protection detected"
+        resp.raise_for_status()
+
+        soup = BeautifulSoup(resp.text, "html.parser")
         for tag in soup(["script", "style", "noscript"]):
             tag.decompose()
-        raw_text = "\n".join(t.strip() for t in soup.get_text("\n").splitlines() if t.strip())
-        return raw_text[:8000]
+        text = "\n".join(t.strip() for t in soup.get_text("\n").splitlines() if t.strip())
+        return text[:8000]
     except Exception as exc:
         return f"Error scrape_url_text: {exc}"
 
 
+
 # ---------- TOOL WRAPPERS ----------
 
 tool_defs = [
@@ -432,9 +453,21 @@ def _extract_observation(raw: str) -> str:
 
 def basic_agent_response(question: str) -> str:
     try:
-        print(f"[DEBUG] ➜ Question: {question}")
-        raw_resp = agent.query(question)
-        cleaned = _extract_observation(str(raw_resp.response if hasattr(raw_resp, "response") else raw_resp))
+        # ⚠️ agente nuevo por pregunta
+        fresh_agent = ReActAgent.from_tools(
+            tools=TOOLS,
+            llm=GeminiLLM(),
+            system_prompt=SYSTEM_PROMPT,
+            verbose=False,
+            max_iterations=25,
+            callback_manager=None,   # sin historial previo
+            handle_parsing_errors=True,
+        )
+
+        raw = fresh_agent.query(question)
+        cleaned = _extract_observation(
+            str(raw.response if hasattr(raw, "response") else raw)
+        )
         return cleaned or "I cannot answer with the available tools."
     except Exception as exc:
         print(f"[ERROR] {exc}")