Deploy v4.6.1 upstream download refresh retry

README.md

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

VERSION

@@ -1 +1 @@
-4.6.0
+4.6.1

routes/downloads.py

@@ -59,7 +59,7 @@ def _ticket_valid(job:dict,request:Request) -> bool:
     except Exception:issued=0
     return bool(issued and time.time()-issued<=DOWNLOAD_TICKET_TTL_SECONDS)
 
-async def _probe(url:str) -> tuple[int,bool,str,str]:
+async def _probe(url:str) -> tuple[int,bool,str,str,int]:
     headers={"User-Agent":"Global-Marine-Data-Agent/4.0.0"}
     async with httpx.AsyncClient(follow_redirects=True,timeout=httpx.Timeout(15,read=30,write=20,pool=15)) as client:
         try:
@@ -67,7 +67,7 @@ async def _probe(url:str) -> tuple[int,bool,str,str]:
             if r.status_code>=400 or not r.headers.get("content-length"):
                 r=await client.get(url,headers={**headers,"Range":"bytes=0-0"})
         except Exception:
-            return 0,False,"",""
+            return 0,False,"","",0
         total=0
         cr=r.headers.get("content-range","")
         if "/" in cr:
@@ -77,7 +77,7 @@ async def _probe(url:str) -> tuple[int,bool,str,str]:
             try:total=int(r.headers.get("content-length") or 0)
             except Exception:total=0
         ranges=("bytes" in str(r.headers.get("accept-ranges","")).lower()) or r.status_code==206
-        return total,ranges,r.headers.get("content-type",""),r.headers.get("content-disposition","")
+        return total,ranges,r.headers.get("content-type",""),r.headers.get("content-disposition",""),r.status_code
 
 
 def _validated_batch_download_url(uid:str, body:dict, url:str) -> bool:
@@ -122,8 +122,34 @@ async def create_download_job(request:Request):
             403,
             "external download host is not allowlisted and URL was not verified as an owned Ocean batch result",
         )
-    total,ranges,ctype,_disp=await _probe(url)
+    total,ranges,ctype,_disp,probe_status=await _probe(url)
+
+    # Signed Ocean links can expire or point at an upstream path that has
+    # rotated. For verified Ocean batch results, refresh the subtask URL on
+    # 401/403/404/410 before creating the managed download job.
+    batch_job_id=str((body or {}).get("batch_job_id") or "").strip()
+    subtask_id=str((body or {}).get("subtask_id") or "").strip()
+    if batch_authorized and probe_status in {401,403,404,410} and batch_job_id and subtask_id:
+        try:
+            refreshed=await OCEAN_BATCH_MANAGER.refresh_download_url(batch_job_id,subtask_id)
+        except Exception:
+            refreshed=None
+        fresh_url=str((refreshed or {}).get("download_url") or "").strip()
+        if fresh_url:
+            url=fresh_url
+            parsed=urlparse(url)
+            total,ranges,ctype,_disp,probe_status=await _probe(url)
+
+    if probe_status and probe_status>=400:
+        raise HTTPException(probe_status,f"upstream download URL is not usable (HTTP {probe_status})")
+
     job=DOWNLOAD_JOBS.create(uid,url,filename,total,ranges,ctype)
+    DOWNLOAD_JOBS.update(
+        job["job_id"],
+        batch_job_id=batch_job_id,
+        subtask_id=subtask_id,
+    )
+    job=DOWNLOAD_JOBS.get(job["job_id"]) or job
     public=DOWNLOAD_JOBS.public(job)
     public["stream_url"]=_stream_url(job)
     public["status_url"]=f"/api/download/jobs/{job['job_id']}"
@@ -147,6 +173,41 @@ async def cancel_download_job(job_id:str,request:Request):
     DOWNLOAD_JOBS.update(job_id,status="canceled",last_activity_ts=time.time())
     return {"ok":True,"job_id":job_id}
 
+
+async def _open_upstream(source:str,headers:dict):
+    client=httpx.AsyncClient(
+        follow_redirects=True,
+        timeout=httpx.Timeout(connect=15,read=None,write=30,pool=15),
+    )
+    try:
+        upstream=await client.send(client.build_request("GET",source,headers=headers),stream=True)
+        return client,upstream
+    except Exception:
+        await client.aclose()
+        raise
+
+
+async def _refresh_job_source_from_batch(job:dict) -> str:
+    batch_job_id=str(job.get("batch_job_id") or "").strip()
+    subtask_id=str(job.get("subtask_id") or "").strip()
+    if not batch_job_id or not subtask_id:
+        return ""
+    try:
+        refreshed=await OCEAN_BATCH_MANAGER.refresh_download_url(batch_job_id,subtask_id)
+    except Exception:
+        return ""
+    fresh_url=str((refreshed or {}).get("download_url") or "").strip()
+    if not fresh_url:
+        return ""
+    DOWNLOAD_JOBS.update(
+        job["job_id"],
+        source_url=fresh_url,
+        error="",
+        last_activity_ts=time.time(),
+    )
+    return fresh_url
+
+
 async def stream_download_job(job_id:str,request:Request):
     job=DOWNLOAD_JOBS.get(job_id)
     if not job:raise HTTPException(404,"download job not found")
@@ -168,19 +229,37 @@ async def stream_download_job(job_id:str,request:Request):
     headers={"User-Agent":"Global-Marine-Data-Agent/4.0.0"}
     if req_range:headers["Range"]=req_range
 
-    client=httpx.AsyncClient(follow_redirects=True,timeout=httpx.Timeout(connect=15,read=None,write=30,pool=15))
     try:
-        upstream=await client.send(client.build_request("GET",source,headers=headers),stream=True)
+        client,upstream=await _open_upstream(source,headers)
     except Exception as exc:
-        await client.aclose()
         DOWNLOAD_JOBS.update(job_id,status="failed",error=str(exc)[:500],last_activity_ts=time.time())
         raise HTTPException(502,"upstream download connection failed") from exc
 
+    # A verified Ocean batch link may expire after job creation. Refresh it
+    # transparently and retry once instead of surfacing a raw upstream 404/403.
+    if upstream.status_code in {401,403,404,410} and job.get("batch_job_id") and job.get("subtask_id"):
+        await upstream.aread()
+        await upstream.aclose();await client.aclose()
+        fresh_source=await _refresh_job_source_from_batch(job)
+        if fresh_source:
+            source=fresh_source
+            try:
+                client,upstream=await _open_upstream(source,headers)
+            except Exception as exc:
+                DOWNLOAD_JOBS.update(job_id,status="failed",error=str(exc)[:500],last_activity_ts=time.time())
+                raise HTTPException(502,"upstream download connection failed after refresh") from exc
+
     if upstream.status_code>=400:
         body=await upstream.aread()
+        code=upstream.status_code
         await upstream.aclose();await client.aclose()
-        DOWNLOAD_JOBS.update(job_id,status="failed",error=body[:500].decode("utf-8","replace"),last_activity_ts=time.time())
-        raise HTTPException(upstream.status_code,"upstream download failed")
+        detail=body[:500].decode("utf-8","replace")
+        DOWNLOAD_JOBS.update(
+            job_id,status="failed",
+            error=(f"HTTP {code}: "+detail)[:500],
+            last_activity_ts=time.time(),
+        )
+        raise HTTPException(code,f"upstream download failed after refresh (HTTP {code})")
 
     # If a Range was requested but upstream ignores it, do not silently return
     # the whole file as if resume succeeded.

static/js/app.js

@@ -1513,9 +1513,9 @@ async function createManagedOceanDownload(state,file){
     }catch(err){
       lastErr=err;
       if(attempt===0){
-        // A stale/expired signed URL commonly surfaces while creating the
-        // managed download. Refresh it once before transport retries.
-        await refreshOceanBatchFileUrl(state,file);
+        // Keep one client-side refresh as a fallback. v4.6.1 also refreshes
+        // server-side before job creation and again at stream time.
+        try{await refreshOceanBatchFileUrl(state,file)}catch(_){}
       }
       if(attempt<2)await new Promise(r=>setTimeout(r,800*Math.pow(2,attempt)));
     }

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.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.1"
 
 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.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.1"
 
 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.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.1"
 
 def test_missing_date_reuses_canonical_region_bbox():
     rt=(ROOT/"services"/"chat_runtime.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.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.1"
 
 def test_new_query_slot_reset():
     rt=(ROOT/"services"/"chat_runtime.py").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.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.1"
 
 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.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.1"
 
 def test_opfs_is_probed_not_assumed():
     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.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.1"
 
 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.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.1"
 
 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.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.1"
 
 def test_frontend_preflight_exists_before_progress():
     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.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.1"
 
 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.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.1"
 
 def test_download_job_backend():
     route=(ROOT/"routes"/"downloads.py").read_text(encoding="utf-8")

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.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.1"
 
 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.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.1"
 
 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.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.1"
 
 def test_parallel_sse_uses_real_blank_line_separator():
     js=(ROOT/"static"/"js"/"app.js").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.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.1"
 
 def test_manifest_has_filename_and_sizes():
     svc=(ROOT/"services"/"ocean_batch.py").read_text(encoding="utf-8")

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.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.1"
 
 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.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.1"
 
 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_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.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.1"
 
 def test_missing_date_never_defaults_to_today():
     rt=(ROOT/"services"/"chat_runtime.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.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.1"
 
 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.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.1"
 
 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.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.1"
 
 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.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.1"
 
 def test_squid_center_uses_repository_membership():
     js=(ROOT/"static"/"js"/"app.js").read_text(encoding="utf-8")

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.0"
+    assert (ROOT / "VERSION").read_text(encoding="utf-8").strip() == "4.6.1"
 
 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.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.1"
 
 def test_quality_confidence_is_now_native_api_metric():
     text=(ROOT/"routes"/"data_health.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.0"
+    assert version == "4.6.1"
     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.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.1"
 
 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.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.1"
 
 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.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.1"
 
 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.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.1"
 
 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.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.1"
 
 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.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.1"
 
 def test_simple_chat_hides_progress_until_needed():
     js=(ROOT/"static"/"js"/"app.js").read_text(encoding="utf-8")

tests/test_sse_heartbeat_v401.py

@@ -3,7 +3,7 @@ import pathlib
 ROOT=pathlib.Path(__file__).resolve().parents[1]
 
 def test_version_401():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.1"
 
 def test_chat_has_independent_heartbeat_wrapper():
     route=(ROOT/"routes"/"chat.py").read_text(encoding="utf-8")

tests/test_ui_avatar_multitask_v440.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.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.1"
 
 def test_assistant_avatar_removed_user_avatar_customizable():
     js=(ROOT/"static"/"js"/"app.js").read_text(encoding="utf-8")

tests/test_unified_download_manager_v392.py

@@ -3,7 +3,7 @@ import pathlib
 ROOT=pathlib.Path(__file__).resolve().parents[1]
 
 def test_version_392():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.1"
 
 def test_download_proxy_route_registered():
     route=(ROOT/"routes"/"downloads.py").read_text(encoding="utf-8")

tests/test_unified_query_v390.py

@@ -4,7 +4,7 @@ from services.unified_query import plan_unified_query
 ROOT=pathlib.Path(__file__).resolve().parents[1]
 
 def test_version_390():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.1"
 
 def test_joint_squid_environment_plan():
     p=plan_unified_query("查询 2002 年 8 月西北太平洋柔鱼记录，并匹配 SST、SSH、CHL")

tests/test_upstream_refresh_retry_v461.py

@@ -0,0 +1,25 @@
+from pathlib import Path
+ROOT=Path(__file__).resolve().parents[1]
+
+def test_version():
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.1"
+
+def test_probe_returns_status_and_rejects_dead_url():
+    py=(ROOT/"routes"/"downloads.py").read_text(encoding="utf-8")
+    assert "probe_status" in py
+    assert "upstream download URL is not usable" in py
+
+def test_batch_identity_persisted_on_download_job():
+    py=(ROOT/"routes"/"downloads.py").read_text(encoding="utf-8")
+    assert "batch_job_id=batch_job_id" in py
+    assert "subtask_id=subtask_id" in py
+
+def test_stream_refreshes_expired_batch_url():
+    py=(ROOT/"routes"/"downloads.py").read_text(encoding="utf-8")
+    assert "async def _refresh_job_source_from_batch" in py
+    assert "refresh_download_url(batch_job_id,subtask_id)" in py
+    assert "upstream download failed after refresh" in py
+
+def test_stream_retries_401_403_404_410():
+    py=(ROOT/"routes"/"downloads.py").read_text(encoding="utf-8")
+    assert "{401,403,404,410}" in py

tests/test_v381_navigation_ocean_intent.py

@@ -3,7 +3,7 @@ import pathlib, ast
 ROOT=pathlib.Path(__file__).resolve().parents[1]
 
 def test_version_381():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.1"
 
 def test_recent_conversation_switches_to_chat():
     js=(ROOT/"static"/"js"/"app.js").read_text(encoding="utf-8")