Deploy v4.6.20 agent reliability fixes

README.md

@@ -10,7 +10,7 @@ pinned: false
 
 # Global Marine Foundation Data Agent
 
-Current UI release: **v4.6.19**.
+Current UI release: **v4.6.20**.
 
 
 ## v3.4.0 稳定性重构（第一阶段）

VERSION

@@ -1 +1 @@
-4.6.19
+4.6.20

codex_harness.py

@@ -12,6 +12,8 @@ from dataclasses import dataclass
 class CodexResult:
     final_response: str
     finish_reason: str = "completed"
+    tool_names: tuple[str, ...] = ()
+    tool_events: tuple[str, ...] = ()
 
 
 class CodexHarness:
@@ -171,7 +173,7 @@ class CodexHarness:
         result = getattr(marine_mcp, short)(**args)
         return CodexHarness._jsonable(result)
 
-    def _request(self, body: dict) -> dict:
+    def _request(self, body: dict, session_id: str) -> dict:
         request = urllib.request.Request(
             self.base_url + "/responses",
             data=json.dumps(body, ensure_ascii=False).encode("utf-8"),
@@ -181,7 +183,7 @@ class CodexHarness:
                 "Content-Type": "application/json",
                 "Accept": "application/json",
                 "User-Agent": "Global-Marine-Foundation/4.5",
-                "x-opencode-session": str(getattr(self, "_session_id", uuid.uuid4())),
+                "x-opencode-session": str(session_id),
             },
         )
         try:
@@ -222,7 +224,7 @@ class CodexHarness:
     def run(self, prompt, session_id=None):
         if not self.api_key:
             raise RuntimeError("OPENCODE_GO_API_KEY is not configured")
-        self._session_id = str(session_id or uuid.uuid4())
+        request_session_id = str(session_id or uuid.uuid4())
         full_prompt = (self.system_prompt + "\n\n" + prompt).strip()
         tools = self._tools()
         payload = self._request({
@@ -230,7 +232,9 @@ class CodexHarness:
             "input": full_prompt,
             "tools": tools,
             "tool_choice": "auto",
-        })
+        }, request_session_id)
+        tool_names = []
+        tool_events = []
 
         # Responses can contain multiple tool calls.  Execute them locally,
         # then continue the same Responses conversation until text is final.
@@ -240,10 +244,18 @@ class CodexHarness:
                 break
             outputs = []
             for call in calls:
+                if call["name"] not in tool_names:
+                    tool_names.append(call["name"])
                 try:
                     value = self._run_tool(call["name"], call["arguments"])
                 except Exception as exc:
                     value = {"status": "error", "detail": str(exc)[:1000]}
+                if len(tool_events)<40:
+                    tool_events.append(json.dumps({
+                        "name":call["name"],
+                        "arguments":call["arguments"],
+                        "result":value,
+                    },ensure_ascii=False,default=str)[:12000])
                 outputs.append({
                     "type": "function_call_output",
                     "call_id": call["call_id"],
@@ -256,11 +268,11 @@ class CodexHarness:
                 "tools": tools,
                 "tool_choice": "auto",
             }
-            payload = self._request(next_body)
+            payload = self._request(next_body, request_session_id)
         else:
             raise RuntimeError("OpenCode Go tool loop exceeded 8 rounds")
 
         answer = self._text(payload)
         if not answer:
             raise RuntimeError("OpenCode Go returned no text: " + json.dumps(payload, ensure_ascii=False)[:1200])
-        return CodexResult(final_response=answer)
+        return CodexResult(final_response=answer, tool_names=tuple(tool_names), tool_events=tuple(tool_events))

codex_native_harness.py

@@ -9,6 +9,7 @@ from __future__ import annotations
 
 import json
 import os
+import re
 import shutil
 import subprocess
 import uuid
@@ -20,6 +21,8 @@ from typing import Any
 class CodexResult:
     final_response: str
     finish_reason: str = "completed"
+    tool_names: tuple[str, ...] = ()
+    tool_events: tuple[str, ...] = ()
 
 
 def _text_from_value(value: Any) -> str:
@@ -52,6 +55,27 @@ def _event_text(event: dict[str, Any]) -> str:
     return ""
 
 
+_MARINE_TOOL_RE = re.compile(r"\bmcp_marine_[A-Za-z0-9_]+\b")
+
+def _tool_names_from_event(event: dict[str, Any]) -> list[str]:
+    if not isinstance(event, dict):
+        return []
+    event_type=str(event.get("type") or "").lower()
+    item=event.get("item") if isinstance(event.get("item"),dict) else {}
+    item_type=str(item.get("type") or "").lower()
+    tool_shaped=(
+        any(token in event_type for token in ("tool","mcp","function"))
+        or any(token in item_type for token in ("tool","mcp","function"))
+    )
+    if not tool_shaped:
+        return []
+    try:
+        raw=json.dumps(event,ensure_ascii=False,default=str)
+    except Exception:
+        raw=str(event)
+    return list(dict.fromkeys(_MARINE_TOOL_RE.findall(raw)))
+
+
 class CodexNativeHarness:
     """Run the official Codex CLI with the configured MCP server."""
 
@@ -142,6 +166,8 @@ class CodexNativeHarness:
             raise RuntimeError(f"无法启动官方 Codex CLI: {exc}") from exc
 
         candidates: list[str] = []
+        tool_names: list[str] = []
+        tool_events: list[str] = []
         for line in (completed.stdout or "").splitlines():
             raw = line.strip()
             if not raw:
@@ -154,6 +180,16 @@ class CodexNativeHarness:
                 text = _event_text(event)
                 if text:
                     candidates.append(text)
+                names=_tool_names_from_event(event)
+                if names:
+                    for name in names:
+                        if name not in tool_names:
+                            tool_names.append(name)
+                    if len(tool_events)<40:
+                        try:
+                            tool_events.append(json.dumps(event,ensure_ascii=False,default=str)[:12000])
+                        except Exception:
+                            tool_events.append(str(event)[:12000])
 
         if completed.returncode != 0:
             stderr_detail = (completed.stderr or "").strip()[-1200:]
@@ -172,4 +208,4 @@ class CodexNativeHarness:
         answer = candidates[-1].strip() if candidates else ""
         if not answer:
             raise RuntimeError("官方 Codex CLI 没有返回最终文本")
-        return CodexResult(final_response=answer)
+        return CodexResult(final_response=answer, tool_names=tuple(tool_names), tool_events=tuple(tool_events))

services/chat_runtime.py

@@ -535,11 +535,30 @@ async def harness_stream_chat(tid,prompt):
         tid,
         USER_SYSTEM,
     )
+    history_context=""
+    try:
+        history_context=_format_recent_thread_history(
+            tid,
+            limit=12,
+            max_chars=24000,
+        )
+    except Exception:
+        history_context=""
 
     harness_prompt=(
         "[APPLICATION_CONTEXT]\n"
         + app_context
         + "\n[/APPLICATION_CONTEXT]\n\n"
+        + (
+            "[PRIOR_CONVERSATION_HISTORY]\n"
+            + history_context
+            + "\n[/PRIOR_CONVERSATION_HISTORY]\n\n"
+            + "[HISTORY_INSTRUCTION]\n"
+            + "Use prior conversation only to resolve references and continuity. "
+              "The current user message has priority over older content.\n"
+            + "[/HISTORY_INSTRUCTION]\n\n"
+            if history_context else ""
+        )
         + "[CURRENT_USER_MESSAGE]\n"
         + prompt
         + "\n[/CURRENT_USER_MESSAGE]"
@@ -591,6 +610,23 @@ async def harness_stream_chat(tid,prompt):
                 "Codex Harness 没有返回有效文本。"
             )
 
+        tool_names=tuple(getattr(result,"tool_names",()) or ())
+        tool_events=tuple(getattr(result,"tool_events",()) or ())
+        export_tool_completed=any(
+            name.endswith("marine_export")
+            or name.endswith("marine_export_range")
+            or name.endswith("_export")
+            for name in tool_names
+        )
+        export_error=_ocean_export_execution_error(
+            prompt,
+            export_tool_completed=export_tool_completed,
+            tool_result_text="\n".join(tool_events),
+            final_answer=final_answer,
+        )
+        if export_error:
+            raise RuntimeError(export_error)
+
         log.info(
             "Codex Harness completed: "
             "thread=%s model=%s reason=%s uploads=%s",
@@ -628,12 +664,11 @@ async def harness_stream_chat(tid,prompt):
             len(pending_uploads),
         )
 
+        public_error=_public_error(str(exc))
         yield out(
             "error",
             {
-                "text":
-                    "Codex Harness 调用失败："
-                    + str(exc)[:500],
+                "text":public_error,
                 "stage":"harness",
             },
         )
@@ -655,14 +690,23 @@ def _is_runtime_info_prompt(prompt: str) -> bool:
 
 
 def _is_marine_health_prompt(prompt: str) -> bool:
-    """Recognize a live Marine API status question without invoking the model."""
-    text = str(prompt or "").strip().lower()
-    health_terms = (
+    """Recognize actual connectivity/status questions, not any domain mention."""
+    text=str(prompt or "").strip().lower()
+    if not text:
+        return False
+    explicit_phrases=(
         "海洋数据服务器连接", "检查海洋数据服务器", "数据服务器连接",
-        "三个数据域", "三个域是否在线", "ocean、tuna、squid",
-        "ocean, tuna, squid", "marine health", "marine server health",
+        "三个域是否在线", "三个数据域是否在线", "marine health",
+        "marine server health",
+    )
+    if any(term in text for term in explicit_phrases):
+        return True
+    status_terms=(
+        "在线","离线","连接","连通","状态","健康","可用","不可用",
+        "正常吗","是否正常","reachable","online","offline","status","health",
     )
-    return any(term in text for term in health_terms)
+    domain_terms=("ocean","tuna","squid","marine","数据服务器","数据域")
+    return any(x in text for x in status_terms) and any(x in text for x in domain_terms)
 
 
 def _is_fisheries_inventory_prompt(prompt: str) -> bool:
@@ -795,55 +839,81 @@ async def _direct_fisheries_inventory_answer(prompt: str) -> str:
 
 
 async def _direct_marine_health_answer():
-    """Query the configured Marine API directly for a deterministic status answer."""
-    httpx_module = globals().get("httpx")
+    """Query live domain status without inferring unavailable states."""
+    httpx_module=globals().get("httpx")
     if httpx_module is None:
         try:
             import httpx as httpx_module
         except Exception as exc:
             return f"海洋数据服务器连接检查失败：HTTP 客户端不可用（{exc}）"
-    base = str(globals().get("MARINE_API_URL") or "").rstrip("/")
+    base=str(globals().get("MARINE_API_URL") or "").rstrip("/")
     if not base:
         return "海洋数据服务器未配置 MARINE_API_URL。"
 
-    candidates = [f"{base}/health"]
-    # HF may expose the school API below the app's /marine reverse-proxy path.
+    def status_label(value):
+        if isinstance(value,dict):
+            value=value.get("status",value.get("online",value.get("available")))
+        if value is True:
+            return "在线"
+        if value is False:
+            return "离线/不可用"
+        low=str(value or "").strip().lower()
+        if low in {"ok","online","ready","available","healthy","true","1"}:
+            return "在线"
+        if low in {"offline","down","unavailable","error","false","0"}:
+            return "离线/不可用"
+        return "未确认"
+
+    candidates=[f"{base}/domains"]
     if not base.endswith("/marine"):
-        candidates.append(f"{base}/marine/health")
-
-    last_error = ""
-    async with httpx_module.AsyncClient(timeout=12.0, follow_redirects=True) as client:
+        candidates.append(f"{base}/marine/domains")
+    last_error=""
+    async with httpx_module.AsyncClient(timeout=12.0,follow_redirects=True) as client:
         for url in candidates:
             try:
-                response = await client.get(url)
+                response=await client.get(url)
+                if not response.is_success:
+                    last_error=f"HTTP {response.status_code}"
+                    continue
+                payload=response.json()
+                domain_payload=payload.get("domains") if isinstance(payload,dict) else None
+                if not isinstance(domain_payload,(dict,list)):
+                    domain_payload=payload if isinstance(payload,(dict,list)) else None
+                labels={key:"未确认" for key in ("ocean","tuna","squid")}
+                if isinstance(domain_payload,dict):
+                    for key in labels:
+                        if key in domain_payload:
+                            labels[key]=status_label(domain_payload.get(key))
+                elif isinstance(domain_payload,list):
+                    present={str(x.get("name") if isinstance(x,dict) else x).lower() for x in domain_payload}
+                    for key in labels:
+                        labels[key]="在线" if key in present else "未确认"
+                return (
+                    "Marine 数据服务已连通。\n"
+                    f"- Ocean：{labels['ocean']}\n"
+                    f"- Tuna：{labels['tuna']}\n"
+                    f"- Squid：{labels['squid']}\n"
+                    "未确认表示服务器响应中没有足够状态字段，平台不会把它自动当成在线。"
+                )
+            except Exception as exc:
+                last_error=str(exc)
+
+    # Fallback health only proves the API is reachable, not that each domain is online.
+    health_urls=[f"{base}/health"]
+    if not base.endswith("/marine"):
+        health_urls.append(f"{base}/marine/health")
+    async with httpx_module.AsyncClient(timeout=12.0,follow_redirects=True) as client:
+        for url in health_urls:
+            try:
+                response=await client.get(url)
                 if response.is_success:
-                    payload = response.json()
-                    domains = payload.get("domains") if isinstance(payload, dict) else None
-                    labels = {
-                        "ocean": "在线",
-                        "tuna": "在线",
-                        "squid": "在线",
-                    }
-                    if isinstance(domains, dict):
-                        for key in labels:
-                            value = domains.get(key)
-                            if isinstance(value, dict):
-                                value = value.get("status") or value.get("online")
-                            if value in (False, "offline", "未连接", "不可用"):
-                                labels[key] = "离线/不可用"
-                    elif isinstance(domains, list):
-                        for key in labels:
-                            if key not in {str(item).lower() for item in domains}:
-                                labels[key] = "未在健康响应中列出"
                     return (
-                        "海洋数据服务器连接正常。\n"
-                        f"- Ocean：{labels['ocean']}\n"
-                        f"- Tuna：{labels['tuna']}\n"
-                        f"- Squid：{labels['squid']}"
+                        "Marine API 可以连接，但当前未取得 Ocean/Tuna/Squid 的逐域状态。"
+                        "请在“设置 → 系统健康”中重新检测详细状态。"
                     )
-                last_error = f"HTTP {response.status_code}"
+                last_error=f"HTTP {response.status_code}"
             except Exception as exc:
-                last_error = str(exc)
+                last_error=str(exc)
     return f"海洋数据服务器连接检查失败：{last_error[:240]}"
 
 

static/js/app.js

@@ -340,7 +340,7 @@ function persist(role,text,meta=""){
   if(role==="assistant"&&meta!=="error")refreshSessionSummary(x,true);
   setUpdated(x);save();hist()
 }
-function historyPayload(x,limit=8){
+function historyPayload(x,limit=12){
   if(!x)return[];
   const items=[];
   for(const m of (x.messages||[])){

tests/test_agent_reliability_v4620.py

@@ -0,0 +1,51 @@
+from pathlib import Path
+ROOT=Path(__file__).resolve().parents[1]
+
+def test_version():
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
+
+def test_harness_receives_recent_conversation_history():
+    py=(ROOT/"services/chat_runtime.py").read_text(encoding="utf-8")
+    assert "_format_recent_thread_history(" in py
+    assert "[PRIOR_CONVERSATION_HISTORY]" in py
+    assert "max_chars=24000" in py
+
+def test_health_intent_does_not_trigger_on_domain_names_alone():
+    py=(ROOT/"services/chat_runtime.py").read_text(encoding="utf-8")
+    block=py[py.index("def _is_marine_health_prompt"):py.index("def _is_fisheries_inventory_prompt")]
+    assert '"ocean、tuna、squid"' not in block
+    assert "status_terms" in block
+    assert "domain_terms" in block
+
+def test_direct_health_never_defaults_all_domains_online():
+    py=(ROOT/"services/chat_runtime.py").read_text(encoding="utf-8")
+    block=py[py.index("async def _direct_marine_health_answer"):py.index("def _is_explicit_new_data_query")]
+    assert 'labels={key:"未确认"' in block
+    assert '/domains' in block
+    assert "平台不会把它自动当成在线" in block
+
+def test_native_harness_preserves_tool_evidence():
+    py=(ROOT/"codex_native_harness.py").read_text(encoding="utf-8")
+    assert "tool_names: tuple[str, ...]" in py
+    assert "_tool_names_from_event" in py
+    assert "tool_events=tuple(tool_events)" in py
+
+def test_harness_export_is_fail_closed():
+    py=(ROOT/"services/chat_runtime.py").read_text(encoding="utf-8")
+    assert 'tool_names=tuple(getattr(result,"tool_names"' in py
+    assert "export_tool_completed=any(" in py
+    assert "_ocean_export_execution_error(" in py
+
+def test_adapter_does_not_store_shared_mutable_session_id():
+    py=(ROOT/"codex_harness.py").read_text(encoding="utf-8")
+    assert "request_session_id" in py
+    assert "self._session_id =" not in py
+
+def test_harness_errors_are_sanitized():
+    py=(ROOT/"services/chat_runtime.py").read_text(encoding="utf-8")
+    assert "public_error=_public_error(str(exc))" in py
+    assert '"text":public_error' in py
+
+def test_frontend_sends_more_recent_context():
+    js=(ROOT/"static/js/app.js").read_text(encoding="utf-8")
+    assert "function historyPayload(x,limit=12)" in js

tests/test_api_entry_preflight_v456.py

@@ -2,7 +2,7 @@ from pathlib import Path
 ROOT=Path(__file__).resolve().parents[1]
 
 def test_version():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.15"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_guard_is_before_auth_and_dispatch():
     chat=(ROOT/"routes"/"chat.py").read_text(encoding="utf-8")

tests/test_chat_lifecycle_progress_v393.py

@@ -3,7 +3,7 @@ import pathlib
 ROOT=pathlib.Path(__file__).resolve().parents[1]
 
 def test_version_393():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.15"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_frontend_lifecycle_progress():
     js=(ROOT/"static"/"js"/"app.js").read_text(encoding="utf-8")

tests/test_clarification_ui_v454.py

@@ -2,7 +2,7 @@ from pathlib import Path
 ROOT=Path(__file__).resolve().parents[1]
 
 def test_version():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.15"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_missing_date_reuses_canonical_region_bbox():
     rt=(ROOT/"services"/"chat_runtime.py").read_text(encoding="utf-8")

tests/test_classification_cleanup_v466.py

@@ -2,7 +2,7 @@ from pathlib import Path
 ROOT=Path(__file__).resolve().parents[1]
 
 def test_version():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.15"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_seaaroundus_alias():
     py=(ROOT/"sidebar_catalog.py").read_text(encoding="utf-8")

tests/test_context_and_multitask_finalize_v451.py

@@ -2,7 +2,7 @@ from pathlib import Path
 ROOT=Path(__file__).resolve().parents[1]
 
 def test_version():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.15"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_new_query_slot_reset():
     rt=(ROOT/"services"/"chat_runtime.py").read_text(encoding="utf-8")

tests/test_conversation_summary_v4613.py

@@ -2,7 +2,7 @@ from pathlib import Path
 ROOT=Path(__file__).resolve().parents[1]
 
 def test_version():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.15"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_frontend_auto_summary_and_manual_override():
     js=(ROOT/"static/js/app.js").read_text(encoding="utf-8")

tests/test_download_host_authorization_v460.py

@@ -2,7 +2,7 @@ from pathlib import Path
 ROOT=Path(__file__).resolve().parents[1]
 
 def test_version():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.15"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_batch_url_authorization_helper_exists():
     py=(ROOT/"routes"/"downloads.py").read_text(encoding="utf-8")

tests/test_download_opfs_fallback_v459.py

@@ -2,7 +2,7 @@ from pathlib import Path
 ROOT=Path(__file__).resolve().parents[1]
 
 def test_version():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.15"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_opfs_is_probed_not_assumed():
     js=(ROOT/"static"/"js"/"app.js").read_text(encoding="utf-8")

tests/test_download_overlay_v4618.py

@@ -2,7 +2,7 @@ from pathlib import Path
 ROOT=Path(__file__).resolve().parents[1]
 
 def test_version():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.18"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_native_download_handoff_finishes_overlay():
     js=(ROOT/"static/js/app.js").read_text(encoding="utf-8")

tests/test_download_progress_v391.py

@@ -3,7 +3,7 @@ import pathlib
 ROOT=pathlib.Path(__file__).resolve().parents[1]
 
 def test_version_391():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.15"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_p1_label_removed():
     js=(ROOT/"static"/"js"/"app.js").read_text(encoding="utf-8")

tests/test_download_resilience_v422.py

@@ -3,7 +3,7 @@ import pathlib
 ROOT=pathlib.Path(__file__).resolve().parents[1]
 
 def test_version():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.15"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_refresh_route_registered():
     t=(ROOT/"routes"/"ocean_batch.py").read_text(encoding="utf-8")

tests/test_frontend_preflight_v457.py

@@ -2,7 +2,7 @@ from pathlib import Path
 ROOT=Path(__file__).resolve().parents[1]
 
 def test_version():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.15"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_frontend_preflight_exists_before_progress():
     js=(ROOT/"static"/"js"/"app.js").read_text(encoding="utf-8")

tests/test_history_dedupe_recent_summary_v4614.py

@@ -2,7 +2,7 @@ from pathlib import Path
 ROOT=Path(__file__).resolve().parents[1]
 
 def test_version():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.15"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_frontend_dedupe_and_merge():
     js=(ROOT/"static/js/app.js").read_text(encoding="utf-8")

tests/test_history_sidebar_v373.py

@@ -3,7 +3,7 @@ import pathlib
 ROOT=pathlib.Path(__file__).resolve().parents[1]
 
 def test_version_373():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.15"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_project_history_backend():
     route=(ROOT/"routes"/"project_package.py").read_text(encoding="utf-8")

tests/test_large_download_jobs_v400.py

@@ -3,7 +3,7 @@ import pathlib
 ROOT=pathlib.Path(__file__).resolve().parents[1]
 
 def test_version_400():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.15"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_download_job_backend():
     route=(ROOT/"routes"/"downloads.py").read_text(encoding="utf-8")

tests/test_manual_tasks_v469.py

@@ -2,7 +2,7 @@ from pathlib import Path
 ROOT=Path(__file__).resolve().parents[1]
 
 def test_version():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.15"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_manual_task_backend_exists():
     service=(ROOT/"services/manual_tasks.py").read_text(encoding="utf-8")
@@ -27,4 +27,4 @@ def test_frontend_new_task_controls():
     assert "标记完成" in js
     assert "重新打开" in js
     assert "manual-delete" in js
-    assert "账号服务器持久化（可跨设备）" in js
+    assert "账号同步：" in js and "可跨设备同步" in js and "服务器会话" in js

tests/test_merged_health_v433.py

@@ -3,7 +3,7 @@ from services.ocean_batch import parse_ocean_batch_request
 ROOT=Path(__file__).resolve().parents[1]
 
 def test_merged_version():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_ocean_month_batch_survives_merge():
     p=parse_ocean_batch_request("查询 2002 年 8 月西北太平洋的 SST 数据，并导出为 CSV 文件供我下载")

tests/test_multitask_observability_v442.py

@@ -2,7 +2,7 @@ from pathlib import Path
 ROOT=Path(__file__).resolve().parents[1]
 
 def test_version():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.15"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_frontend_sends_multitask_trace_headers():
     js=(ROOT/"static"/"js"/"app.js").read_text(encoding="utf-8")

tests/test_multitask_sse_finalize_v452.py

@@ -2,7 +2,7 @@ from pathlib import Path
 ROOT=Path(__file__).resolve().parents[1]
 
 def test_version():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.15"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_parallel_sse_uses_real_blank_line_separator():
     js=(ROOT/"static"/"js"/"app.js").read_text(encoding="utf-8")

tests/test_noaa_ramldb_roles_v465.py

@@ -2,7 +2,7 @@ from pathlib import Path
 ROOT=Path(__file__).resolve().parents[1]
 
 def test_version():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.15"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_noaa_and_ramldb_aliases():
     py=(ROOT/"sidebar_catalog.py").read_text(encoding="utf-8")

tests/test_ocean_batch_downloads_v420.py

@@ -3,7 +3,7 @@ import pathlib
 ROOT=pathlib.Path(__file__).resolve().parents[1]
 
 def test_version_420():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.15"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_manifest_has_filename_and_sizes():
     svc=(ROOT/"services"/"ocean_batch.py").read_text(encoding="utf-8")
@@ -17,13 +17,13 @@ def test_frontend_has_one_click_batch_download():
     assert "function startOceanBatchDownloadAll" in js
     assert "function runOceanBatchDownloadQueue" in js
     assert "function waitManagedDownloadStatus" in js
-    assert "下载全部" in js
+    assert "打包 ZIP 下载" in js and "逐个下载" in js
     assert "查看文件" in js
 
 def test_batch_download_uses_managed_range_jobs():
     js=(ROOT/"static"/"js"/"app.js").read_text(encoding="utf-8")
     assert 'j("/api/download/jobs"' in js
-    assert "triggerBrowserSave(child.stream_url" in js
+    assert "triggerBrowserSave(job.stream_url" in js
     assert "resume_supported" in js
     assert "30 秒无新字节" in js
 

tests/test_ocean_batch_routing_v421.py

@@ -4,7 +4,7 @@ from services.ocean_batch import parse_ocean_batch_request
 ROOT=pathlib.Path(__file__).resolve().parents[1]
 
 def test_version_421():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.15"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_exact_user_month_query_routes_to_batch():
     p=parse_ocean_batch_request("查询 2002 年 8 月西北太平洋的 SST 数据，并导出为 CSV 文件供我下载")

tests/test_ocean_batch_v410.py

@@ -4,7 +4,7 @@ from services.ocean_batch import parse_ocean_batch_request
 ROOT=pathlib.Path(__file__).resolve().parents[1]
 
 def test_version_410():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.15"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_month_three_variable_batch_plan():
     p=parse_ocean_batch_request("查询并导出 2002 年 8 月西北太平洋 120°E–140°E、20°N–40°N 的 SST、SSH、CHL 数据，并打包下载")

tests/test_ocean_batch_zip_manifest_v4619.py

@@ -2,7 +2,7 @@ from pathlib import Path
 ROOT=Path(__file__).resolve().parents[1]
 
 def test_version():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.19"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_zip_backend_routes_exist():
     py=(ROOT/"routes/ocean_batch.py").read_text(encoding="utf-8")

tests/test_ocean_date_default_v453.py

@@ -2,7 +2,7 @@ from pathlib import Path
 ROOT=Path(__file__).resolve().parents[1]
 
 def test_version():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.15"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_missing_date_never_defaults_to_today():
     rt=(ROOT/"services"/"chat_runtime.py").read_text(encoding="utf-8")

tests/test_ocean_download_url_base_v462.py

@@ -2,7 +2,7 @@ from pathlib import Path
 ROOT=Path(__file__).resolve().parents[1]
 
 def test_version():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.15"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_generic_public_base_not_used():
     py=(ROOT/"services"/"ocean_batch.py").read_text(encoding="utf-8")

tests/test_p0_finish_v380.py

@@ -3,7 +3,7 @@ import pathlib, re, subprocess, shutil
 ROOT=pathlib.Path(__file__).resolve().parents[1]
 
 def test_version_380():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.15"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_chat_runtime_extracted():
     ui=(ROOT/"ui_server.py").read_text(encoding="utf-8")

tests/test_p0_phase2_v371.py

@@ -3,7 +3,7 @@ import pathlib
 ROOT=pathlib.Path(__file__).resolve().parents[1]
 
 def test_version():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.15"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_frontend_feature_modules_exist():
     html=(ROOT/"app.html").read_text(encoding="utf-8")

tests/test_p0_phase3_v372.py

@@ -3,7 +3,7 @@ import pathlib
 ROOT=pathlib.Path(__file__).resolve().parents[1]
 
 def test_version_372():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.15"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_route_modules_exist():
     for name in ("datasets.py","user_state.py","project_package.py","data_health.py"):

tests/test_platform_reliability_v450.py

@@ -6,7 +6,7 @@ from services.ocean_batch import parse_ocean_batch_request
 ROOT=Path(__file__).resolve().parents[1]
 
 def test_version():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.15"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_squid_center_uses_repository_membership():
     js=(ROOT/"static"/"js"/"app.js").read_text(encoding="utf-8")
@@ -15,7 +15,7 @@ def test_squid_center_uses_repository_membership():
     assert "file_count_by_repository" in api
     assert "domains.includes(domain)" in js
     assert "squid_file_count" in js
-    assert "实时仓库文件树口径" in js
+    assert "Hugging Face main 实时文件树" in js
 
 def test_single_ocean_export_forces_managed_proxy():
     js=(ROOT/"static"/"js"/"app.js").read_text(encoding="utf-8")

tests/test_product_finish_v4615.py

@@ -2,7 +2,7 @@ from pathlib import Path
 ROOT=Path(__file__).resolve().parents[1]
 
 def test_version():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.15"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_system_health_is_settings_embedded_and_modular():
     app=(ROOT/"static/js/app.js").read_text(encoding="utf-8")

tests/test_project_package_download_v4617.py

@@ -2,7 +2,7 @@ from pathlib import Path
 ROOT=Path(__file__).resolve().parents[1]
 
 def test_version():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.17"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_project_package_download_is_capability_url():
     py=(ROOT/"routes/project_package.py").read_text(encoding="utf-8")
@@ -21,4 +21,4 @@ def test_same_origin_download_probes_before_native_save():
 def test_project_download_button_explains_browser_handoff():
     js=(ROOT/"static/js/project-package.js").read_text(encoding="utf-8")
     assert "正在交给浏览器" in js
-    assert "已交给浏览器下载" in js
+    assert "已交给浏览器；实际完成状态请看浏览器下载栏" in js

tests/test_quality_center_v362.py

@@ -3,7 +3,7 @@ import pathlib
 ROOT = pathlib.Path(__file__).resolve().parents[1]
 
 def test_version_371():
-    assert (ROOT / "VERSION").read_text(encoding="utf-8").strip() == "4.6.15"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_native_health_backend():
     text = (ROOT / "routes" / "data_health.py").read_text(encoding="utf-8")

tests/test_quality_trust_v361.py

@@ -2,7 +2,7 @@ from pathlib import Path
 ROOT=Path(__file__).resolve().parents[1]
 
 def test_version_current():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.15"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_quality_confidence_is_now_native_api_metric():
     text=(ROOT/"routes"/"data_health.py").read_text(encoding="utf-8")

tests/test_reference_cleanup_v468.py

@@ -2,7 +2,7 @@ from pathlib import Path
 ROOT=Path(__file__).resolve().parents[1]
 
 def test_version():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.15"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_reference_and_reproducibility_are_auxiliary():
     py=(ROOT/"routes"/"datasets.py").read_text(encoding="utf-8")

tests/test_release_stability.py

@@ -7,7 +7,7 @@ def test_version_is_single_source():
     version = (ROOT / "VERSION").read_text(encoding="utf-8").strip()
     ui = (ROOT / "ui_server.py").read_text(encoding="utf-8")
     html = (ROOT / "app.html").read_text(encoding="utf-8")
-    assert version == "4.6.15"
+    assert version == '4.6.20'
     assert 'with_name("VERSION")' in ui
     assert "__APP_VERSION__" in html
 

tests/test_resumable_batch_download_v458.py

@@ -2,7 +2,7 @@ from pathlib import Path
 ROOT=Path(__file__).resolve().parents[1]
 
 def test_version():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.15"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_network_loss_pauses_not_fails_all():
     js=(ROOT/"static"/"js"/"app.js").read_text(encoding="utf-8")

tests/test_route_region_clarification_v455.py

@@ -2,7 +2,7 @@ from pathlib import Path
 ROOT=Path(__file__).resolve().parents[1]
 
 def test_version():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.15"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_route_guard_exists_before_agent_dispatch():
     chat=(ROOT/"routes"/"chat.py").read_text(encoding="utf-8")

tests/test_runtime_hotfix_v376.py

@@ -3,7 +3,7 @@ import pathlib
 ROOT=pathlib.Path(__file__).resolve().parents[1]
 
 def test_version_376():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.15"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_no_stray_async_before_sidebar_toggle():
     js=(ROOT/"static"/"js"/"app.js").read_text(encoding="utf-8")

tests/test_sidebar_collapse_v374.py

@@ -3,7 +3,7 @@ import pathlib
 ROOT=pathlib.Path(__file__).resolve().parents[1]
 
 def test_version_374():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.15"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_sidebar_toggle_markup():
     html=(ROOT/"app.html").read_text(encoding="utf-8")

tests/test_sidebar_partial_collapse_v375.py

@@ -3,7 +3,7 @@ import pathlib
 ROOT=pathlib.Path(__file__).resolve().parents[1]
 
 def test_version_375():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.15"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_sidebar_order_and_groups():
     html=(ROOT/"app.html").read_text(encoding="utf-8")

tests/test_smart_progress_avatar_sync_v441.py

@@ -2,7 +2,7 @@ from pathlib import Path
 ROOT=Path(__file__).resolve().parents[1]
 
 def test_version():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.15"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_simple_chat_hides_progress_until_needed():
     js=(ROOT/"static"/"js"/"app.js").read_text(encoding="utf-8")

tests/test_source_mapping_roles_v464.py

@@ -2,7 +2,7 @@ from pathlib import Path
 ROOT=Path(__file__).resolve().parents[1]
 
 def test_version():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.15"
+    assert (ROOT/'VERSION').read_text(encoding='utf-8').strip()=='4.6.20'
 
 def test_new_source_mappings():
     py=(ROOT/"sidebar_catalog.py").read_text(encoding="utf-8")