Deploy v4.6.9 manual task center

README.md

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

VERSION

@@ -1 +1 @@
-4.6.8
+4.6.9

routes/manual_tasks.py

@@ -0,0 +1,66 @@
+from __future__ import annotations
+from fastapi import HTTPException, Request
+
+
+def _inject(context):
+    globals().update(context)
+
+
+async def create_manual_task(request:Request):
+    try:
+        body=await request.json()
+    except Exception:
+        raise HTTPException(400,"invalid json")
+    uid,_=await resolve_request_user(request,str(body.get("user_id") or ""))
+    try:
+        task=MANUAL_TASK_STORE.create(
+            uid,
+            body.get("title"),
+            body.get("description") or "",
+            body.get("status") or "pending",
+        )
+    except ValueError as exc:
+        raise HTTPException(400,str(exc))
+    try:
+        await safe_memory_event(uid,"manual_task_created",{"task_id":task["task_id"],"title":task["title"],"status":task["status"]})
+    except Exception:
+        pass
+    return {"status":"ok","task":task,"storage":MANUAL_TASK_STORE.storage_mode}
+
+
+async def update_manual_task(task_id:str,request:Request):
+    try:
+        body=await request.json()
+    except Exception:
+        raise HTTPException(400,"invalid json")
+    uid,_=await resolve_request_user(request,str(body.get("user_id") or ""))
+    try:
+        task=MANUAL_TASK_STORE.update(uid,task_id,body)
+    except ValueError as exc:
+        raise HTTPException(400,str(exc))
+    if not task:
+        raise HTTPException(404,"manual task not found")
+    try:
+        await safe_memory_event(uid,"manual_task_updated",{"task_id":task_id,"status":task.get("status")})
+    except Exception:
+        pass
+    return {"status":"ok","task":task,"storage":MANUAL_TASK_STORE.storage_mode}
+
+
+async def delete_manual_task(task_id:str,request:Request):
+    supplied=str(request.query_params.get("user_id") or "").strip()
+    uid,_=await resolve_request_user(request,supplied)
+    if not MANUAL_TASK_STORE.delete(uid,task_id):
+        raise HTTPException(404,"manual task not found")
+    try:
+        await safe_memory_event(uid,"manual_task_deleted",{"task_id":task_id})
+    except Exception:
+        pass
+    return {"status":"ok","task_id":task_id}
+
+
+def register_manual_task_routes(app,context):
+    _inject(context)
+    app.add_api_route("/api/sidebar/tasks/manual",create_manual_task,methods=["POST"])
+    app.add_api_route("/api/sidebar/tasks/manual/{task_id}",update_manual_task,methods=["PATCH"])
+    app.add_api_route("/api/sidebar/tasks/manual/{task_id}",delete_manual_task,methods=["DELETE"])

services/manual_tasks.py

@@ -0,0 +1,109 @@
+from __future__ import annotations
+
+import json
+import secrets
+import time
+from datetime import datetime
+from pathlib import Path
+from threading import RLock
+from typing import Any
+
+
+class ManualTaskStore:
+    VALID_STATUSES={"pending","running","completed","failed"}
+
+    def __init__(self, root:Path, valid_user_id, max_tasks:int=300):
+        self.root=Path(root)/"manual_tasks"
+        self.root.mkdir(parents=True,exist_ok=True)
+        self.valid_user_id=valid_user_id
+        self.max_tasks=max(20,int(max_tasks))
+        self.lock=RLock()
+
+    @property
+    def storage_mode(self)->str:
+        return "persistent" if str(self.root).startswith("/data/") else "server-session"
+
+    def _file(self,user_id:str)->Path:
+        if not self.valid_user_id(user_id):
+            raise ValueError("invalid user_id")
+        return self.root/f"{user_id}.json"
+
+    def _read(self,user_id:str)->list[dict[str,Any]]:
+        path=self._file(user_id)
+        try:
+            raw=json.loads(path.read_text(encoding="utf-8"))
+            return raw if isinstance(raw,list) else []
+        except Exception:
+            return []
+
+    def _write(self,user_id:str,tasks:list[dict[str,Any]])->None:
+        path=self._file(user_id)
+        tmp=path.with_suffix(".tmp")
+        tmp.write_text(json.dumps(tasks[:self.max_tasks],ensure_ascii=False,indent=2),encoding="utf-8")
+        tmp.replace(path)
+
+    def _clean_text(self,value:Any,limit:int)->str:
+        return " ".join(str(value or "").replace("\x00","").split())[:limit]
+
+    def _normalize_status(self,value:Any)->str:
+        status=str(value or "pending").strip().lower()
+        return status if status in self.VALID_STATUSES else "pending"
+
+    def list_user(self,user_id:str,limit:int=200)->list[dict[str,Any]]:
+        with self.lock:
+            tasks=self._read(user_id)
+        tasks.sort(key=lambda x:str(x.get("updated_at") or x.get("created_at") or ""),reverse=True)
+        return tasks[:max(1,min(int(limit or 200),self.max_tasks))]
+
+    def create(self,user_id:str,title:str,description:str="",status:str="pending")->dict[str,Any]:
+        now=datetime.now().astimezone().isoformat(timespec="seconds")
+        task={
+            "kind":"manual",
+            "task_id":"manual_"+secrets.token_hex(8),
+            "user_id":user_id,
+            "title":self._clean_text(title,160),
+            "description":self._clean_text(description,4000),
+            "status":self._normalize_status(status),
+            "source":"manual",
+            "created_at":now,
+            "updated_at":now,
+        }
+        if not task["title"]:
+            raise ValueError("title is required")
+        with self.lock:
+            tasks=self._read(user_id)
+            tasks=[task]+[x for x in tasks if x.get("task_id")!=task["task_id"]]
+            self._write(user_id,tasks)
+        return task
+
+    def update(self,user_id:str,task_id:str,patch:dict[str,Any])->dict[str,Any]|None:
+        with self.lock:
+            tasks=self._read(user_id)
+            target=None
+            for task in tasks:
+                if str(task.get("task_id") or "")==task_id:
+                    target=task
+                    break
+            if target is None:
+                return None
+            if "title" in patch:
+                title=self._clean_text(patch.get("title"),160)
+                if not title:
+                    raise ValueError("title is required")
+                target["title"]=title
+            if "description" in patch:
+                target["description"]=self._clean_text(patch.get("description"),4000)
+            if "status" in patch:
+                target["status"]=self._normalize_status(patch.get("status"))
+            target["updated_at"]=datetime.now().astimezone().isoformat(timespec="seconds")
+            self._write(user_id,tasks)
+            return dict(target)
+
+    def delete(self,user_id:str,task_id:str)->bool:
+        with self.lock:
+            tasks=self._read(user_id)
+            kept=[x for x in tasks if str(x.get("task_id") or "")!=task_id]
+            if len(kept)==len(tasks):
+                return False
+            self._write(user_id,kept)
+        return True

static/js/app.js

@@ -1087,8 +1087,8 @@ async function renderServices(){
 
 const TASK_OPERATION_ZH={quality_check:"数据质量检查",marine_export:"海洋数据导出",marine_query:"海洋数据查询",marine_subset:"海洋区域裁剪",fisheries_query:"渔业数据查询",task:"数据处理任务"};
 function taskOperationLabel(v){return TASK_OPERATION_ZH[String(v||"")]||String(v||"数据处理任务")}
-function taskStatusGroup(v){const s=String(v||"");if(/completed|done|success|成功|完成/i.test(s))return "completed";if(/failed|error|失败|异常/i.test(s))return "failed";return "running"}
-function taskStatusLabel(v){const g=taskStatusGroup(v);return g==="completed"?"已完成":g==="failed"?"失败":"处理中"}
+function taskStatusGroup(v){const s=String(v||"");if(/completed|done|success|成功|完成/i.test(s))return "completed";if(/failed|error|失败|异常/i.test(s))return "failed";if(/pending|todo|queued|待处理|等待/i.test(s))return "pending";return "running"}
+function taskStatusLabel(v){const g=taskStatusGroup(v);return g==="completed"?"已完成":g==="failed"?"失败":g==="pending"?"待处理":"处理中"}
 function taskProgressHtml(task){
   const g=taskStatusGroup(task.status),explicit=Number(task.progress);
   if(task.progress!==null&&task.progress!==undefined&&Number.isFinite(explicit))return '<div class="task-progress" title="进度 '+esc(explicit)+'%"><span style="width:'+Math.max(0,Math.min(100,explicit))+'%"></span></div><div class="row-meta">处理进度：'+esc(explicit)+'%</div>';
@@ -1119,21 +1119,68 @@ function assetContinuePrompt(asset){return '请分析这个已生成的数据资
 function openAssetDetail(asset){
   document.querySelector(".drawer-backdrop")?.remove();const wrap=document.createElement("div");wrap.className="drawer-backdrop";wrap.innerHTML='<aside class="detail-drawer" role="dialog" aria-modal="true" aria-label="数据资产详情"><div class="drawer-head"><div><h2>'+esc(asset.name||"未命名资产")+'</h2><p>'+esc(taskOperationLabel(asset.operation))+' · '+esc(taskStatusLabel(asset.status))+'</p></div><button class="drawer-close" aria-label="关闭">×</button></div><div class="task-summary"><div><span>资产编号</span><b>'+esc(asset.asset_id||"-")+'</b></div><div><span>文件大小</span><b>'+esc(formatBytes(asset.size_bytes))+'</b></div><div><span>文件类型</span><b>'+esc(asset.mime_type||"-")+'</b></div><div><span>创建时间</span><b>'+esc(formatTime(asset.created_at))+'</b></div></div><div class="detail-section"><h3>资产来源</h3><div class="row-detail">来源：'+esc(asset.source||"未记录")+(asset.path?'<br>路径：'+esc(asset.path):'')+(asset.thread_id?'<br>关联会话：'+esc(asset.thread_id):'')+'</div></div><div class="card-actions">'+(asset.download_url?'<a class="download" href="'+esc(asset.download_url)+'" target="_blank" rel="noopener">↓ 下载资产</a>':'')+'<button class="view-btn primary asset-chat">在对话中分析</button></div></aside>';document.body.appendChild(wrap);const close=()=>wrap.remove();wrap.querySelector(".drawer-close").onclick=close;wrap.onclick=e=>{if(e.target===wrap)close()};wrap.querySelector(".asset-chat").onclick=()=>{close();goChat(assetContinuePrompt(asset))}
 }
+function openManualTaskEditor(task=null){
+  document.querySelector(".drawer-backdrop")?.remove();
+  const editing=!!task;
+  const wrap=document.createElement("div");wrap.className="drawer-backdrop";
+  wrap.innerHTML='<aside class="detail-drawer" role="dialog" aria-modal="true" aria-label="'+(editing?'编辑任务':'新建任务')+'"><div class="drawer-head"><div><h2>'+(editing?'编辑任务':'新建任务')+'</h2><p>手动任务会绑定当前账号并保存在任务中心。</p></div><button class="drawer-close" aria-label="关闭">×</button></div><div class="detail-tool"><label class="row-detail">任务名称</label><input id="manualTaskTitle" type="text" maxlength="160" placeholder="例如：跨设备同步测试" value="'+esc(task?.title||"")+'"><label class="row-detail" style="display:block;margin-top:12px">任务内容</label><textarea id="manualTaskDescription" rows="7" maxlength="4000" placeholder="写清楚要完成的事情、检查条件或后续动作。">'+esc(task?.description||"")+'</textarea><label class="row-detail" style="display:block;margin-top:12px">状态</label><select id="manualTaskStatus"><option value="pending">待处理</option><option value="running">处理中</option><option value="completed">已完成</option><option value="failed">失败</option></select></div><div class="card-actions"><button id="manualTaskSave" class="view-btn primary">'+(editing?'保存修改':'创建任务')+'</button><button class="view-btn manual-task-cancel">取消</button></div></aside>';
+  document.body.appendChild(wrap);
+  const close=()=>wrap.remove();
+  wrap.querySelector(".drawer-close").onclick=close;
+  wrap.querySelector(".manual-task-cancel").onclick=close;
+  wrap.onclick=e=>{if(e.target===wrap)close()};
+  const status=wrap.querySelector("#manualTaskStatus");status.value=task?.status||"pending";
+  wrap.querySelector("#manualTaskSave").onclick=async()=>{
+    const title=wrap.querySelector("#manualTaskTitle").value.trim();
+    const description=wrap.querySelector("#manualTaskDescription").value.trim();
+    if(!title){toast("请填写任务名称");wrap.querySelector("#manualTaskTitle").focus();return}
+    const btn=wrap.querySelector("#manualTaskSave");btn.disabled=true;
+    try{
+      if(editing){
+        await j("/api/sidebar/tasks/manual/"+encodeURIComponent(task.task_id),{method:"PATCH",body:JSON.stringify({user_id:USER_ID,title,description,status:status.value})});
+        toast("任务已更新");
+      }else{
+        await j("/api/sidebar/tasks/manual",{method:"POST",body:JSON.stringify({user_id:USER_ID,title,description,status:status.value})});
+        toast("任务已创建");
+      }
+      close();await renderTasks();
+    }catch(err){toast("保存失败："+(err.message||String(err)))}
+    finally{btn.disabled=false}
+  };
+  setTimeout(()=>wrap.querySelector("#manualTaskTitle")?.focus(),0);
+}
+
+async function deleteManualTask(task){
+  if(!confirm('确认删除任务“'+(task.title||"未命名任务")+'”？'))return;
+  try{
+    await j("/api/sidebar/tasks/manual/"+encodeURIComponent(task.task_id)+"?user_id="+encodeURIComponent(USER_ID),{method:"DELETE"});
+    toast("任务已删除");await renderTasks();
+  }catch(err){toast("删除失败："+(err.message||String(err)))}
+}
+
 async function renderTasks(){
-  const root=$("workspaceInner");root.innerHTML='<div class="view-head"><div><h1>我的任务</h1><p>查看当前登录用户的数据处理任务和生成的数据资产。</p></div><button id="refreshTasks" class="view-btn">↻ 刷新</button></div><div class="loading">正在读取任务记录…</div>';$("refreshTasks").onclick=renderTasks;
+  const root=$("workspaceInner");root.innerHTML='<div class="view-head"><div><h1>我的任务</h1><p>查看当前登录用户的数据处理任务和生成的数据资产。</p></div><div class="card-actions"><button id="newManualTask" class="view-btn primary">＋ 新建任务</button><button id="refreshTasks" class="view-btn">↻ 刷新</button></div></div><div class="loading">正在读取任务记录…</div>';$("refreshTasks").onclick=renderTasks;$("newManualTask").onclick=()=>openManualTaskEditor();
   try{
-    const data=await j("/api/sidebar/tasks?user_id="+encodeURIComponent(USER_ID)),tasks=data.tasks||[],assets=data.assets||[],localTasks=data.local_tasks||[],allStatus=[...tasks,...localTasks],running=allStatus.filter(x=>["running","queued","transferring","paused"].includes(String(x.status||"").toLowerCase())).length,failed=allStatus.filter(x=>["failed","partial"].includes(String(x.status||"").toLowerCase())).length,completed=allStatus.filter(x=>String(x.status||"").toLowerCase()==="completed").length;
-    let html='<div class="view-head"><div><h1>我的任务</h1><p>'+esc(data.enabled?"任务、结果和数据资产已按当前用户关联":"任务记录服务尚未启用")+'</p></div><button id="refreshTasks" class="view-btn">↻ 刷新</button></div><div class="summary-grid"><div class="summary-card"><strong>'+(tasks.length+localTasks.length)+'</strong><span>全部任务</span></div><div class="summary-card"><strong>'+running+'</strong><span>处理中</span></div><div class="summary-card"><strong>'+completed+'</strong><span>已完成</span></div><div class="summary-card"><strong>'+failed+'</strong><span>失败</span></div><div class="summary-card"><strong>'+assets.length+'</strong><span>数据资产</span></div></div>';
+    const data=await j("/api/sidebar/tasks?user_id="+encodeURIComponent(USER_ID)),tasks=data.tasks||[],assets=data.assets||[],localTasks=data.local_tasks||[],allStatus=[...tasks,...localTasks],pending=allStatus.filter(x=>taskStatusGroup(x.status)==="pending").length,running=allStatus.filter(x=>taskStatusGroup(x.status)==="running").length,failed=allStatus.filter(x=>taskStatusGroup(x.status)==="failed").length,completed=allStatus.filter(x=>taskStatusGroup(x.status)==="completed").length;
+    let html='<div class="view-head"><div><h1>我的任务</h1><p>'+esc(data.enabled?"任务、结果和数据资产已按当前用户关联":"任务记录服务尚未启用")+'</p></div><div class="card-actions"><button id="newManualTask" class="view-btn primary">＋ 新建任务</button><button id="refreshTasks" class="view-btn">↻ 刷新</button></div></div><div class="summary-grid"><div class="summary-card"><strong>'+(tasks.length+localTasks.length)+'</strong><span>全部任务</span></div><div class="summary-card"><strong>'+pending+'</strong><span>待处理</span></div><div class="summary-card"><strong>'+running+'</strong><span>处理中</span></div><div class="summary-card"><strong>'+completed+'</strong><span>已完成</span></div><div class="summary-card"><strong>'+failed+'</strong><span>失败</span></div><div class="summary-card"><strong>'+assets.length+'</strong><span>数据资产</span></div></div><div class="detail-note">手动任务存储：'+esc(data.manual_task_storage==="persistent"?"账号服务器持久化（可跨设备）":"服务器会话存储（未挂��持久卷）")+'。</div>';
     if(data.error)html+='<div class="service-row"><div class="row-detail">'+esc(data.error)+'</div></div>';
     html+='<h3 style="font-size:14px;margin:20px 0 10px">持久化任务</h3><div id="persistentTaskList"></div><div class="filter-bar"><input id="taskSearch" type="search" placeholder="搜索任务类型、编号、来源或关联文件"><select id="taskStatus"><option value="all">全部状态</option><option value="running">处理中</option><option value="completed">已完成</option><option value="failed">失败</option></select><span id="taskCount" class="filter-count"></span></div><h3 style="font-size:14px;margin:20px 0 10px">处理任务</h3><div id="taskList"></div><div class="filter-bar" style="margin-top:20px"><input id="assetSearch" type="search" placeholder="搜索资产名称、类型或来源"><span id="assetCount" class="filter-count"></span></div><h3 style="font-size:14px;margin:12px 0 10px">数据资产</h3><div id="assetList"></div>';
-    root.innerHTML=html;$("refreshTasks").onclick=renderTasks;
+    root.innerHTML=html;$("refreshTasks").onclick=renderTasks;$("newManualTask").onclick=()=>openManualTaskEditor();
     const drawPersistent=()=>{
       const box=$("persistentTaskList");if(!box)return;
       if(!localTasks.length){box.innerHTML='<div class="empty-view"><b>暂无持久化任务</b>Ocean 批量导出和大文件下载任务会保存在这里。</div>';return}
       box.innerHTML=localTasks.map((x,i)=>{
+        if(x.kind==="manual"){const g=taskStatusGroup(x.status);return '<div class="task-row" data-manual-index="'+i+'"><div class="task-head"><b>'+esc(x.title||"手动任务")+'</b><span class="badge '+(g==="completed"?"ok":g==="failed"?"bad":"warn")+'">'+esc(taskStatusLabel(x.status))+'</span></div><div class="row-meta">'+esc(x.task_id||"")+' · 手动创建 · '+esc(formatTime(x.updated_at||x.created_at))+'</div><div class="row-detail">'+esc(x.description||"暂无任务说明")+'</div><div class="card-actions"><button class="view-btn primary manual-chat">在对话中继续</button><button class="view-btn manual-edit">编辑</button>'+(x.status!=="completed"?'<button class="view-btn manual-complete">标记完成</button>':'<button class="view-btn manual-reopen">重新打开</button>')+'<button class="view-btn danger manual-delete">删除</button></div></div>'}
         if(x.kind==="ocean_batch"){const c=x.counts||{},pct=Number(x.progress_percent||0);return '<div class="task-row" data-local-index="'+i+'"><div class="task-head"><b>Ocean 批量导出</b><span class="badge '+(x.status==="completed"?"ok":x.status==="partial"?"bad":"warn")+'">'+esc(x.status||"-")+'</span></div><div class="row-meta">'+esc(x.job_id||"")+' · '+esc(formatTime(x.updated_at||x.created_at))+(x.thread_id?' · 关联会话 '+esc(x.thread_id):'')+'</div><div class="row-detail">'+esc(x.prompt||"")+'</div><div class="ocean-batch-track"><span style="width:'+Math.min(100,pct)+'%"></span></div><div class="row-meta">'+pct.toFixed(0)+'% · 完成 '+esc(c.completed||0)+' / '+esc(x.total||0)+' · 失败 '+esc(c.failed||0)+'</div><div class="card-actions">'+(x.status==="paused"?'<button class="view-btn local-resume">继续任务</button>':'')+((c.failed||0)>0?'<button class="view-btn local-retry">仅重试失败项</button>':'')+'<button class="view-btn local-detail">查看子任务</button>'+(x.thread_id?'<button class="view-btn primary local-chat">回到关联对话</button>':'')+'</div><div class="local-subtasks" hidden></div></div>'}
         return '<div class="task-row"><div class="task-head"><b>大文件下载</b><span class="badge '+(x.status==="completed"?"ok":x.status==="failed"?"bad":"warn")+'">'+esc(x.status||"-")+'</span></div><div class="row-meta">'+esc(x.job_id||"")+' · '+esc(x.filename||"download")+' · '+esc(formatTime(x.updated_at))+'</div><div class="row-detail">已传输 '+esc(formatBytes(x.transferred_bytes||0))+(x.total_bytes?' / '+esc(formatBytes(x.total_bytes)):'')+(x.resume_supported?' · 支持断点续传':'')+'</div></div>'
       }).join('');
+      box.querySelectorAll('[data-manual-index]').forEach(card=>{const x=localTasks[Number(card.dataset.manualIndex)];
+        card.querySelector('.manual-edit')?.addEventListener('click',()=>openManualTaskEditor(x));
+        card.querySelector('.manual-delete')?.addEventListener('click',()=>deleteManualTask(x));
+        card.querySelector('.manual-chat')?.addEventListener('click',()=>goChat('请帮我继续处理这个手动任务。\n任务：'+(x.title||'')+'\n说明：'+(x.description||'')+'\n当前状态：'+taskStatusLabel(x.status)));
+        card.querySelector('.manual-complete')?.addEventListener('click',async()=>{await j('/api/sidebar/tasks/manual/'+encodeURIComponent(x.task_id),{method:'PATCH',body:JSON.stringify({user_id:USER_ID,status:'completed'})});toast('已标记完成');renderTasks()});
+        card.querySelector('.manual-reopen')?.addEventListener('click',async()=>{await j('/api/sidebar/tasks/manual/'+encodeURIComponent(x.task_id),{method:'PATCH',body:JSON.stringify({user_id:USER_ID,status:'pending'})});toast('任务已重新打开');renderTasks()});
+      });
       box.querySelectorAll('[data-local-index]').forEach(card=>{const x=localTasks[Number(card.dataset.localIndex)];
         card.querySelector('.local-resume')?.addEventListener('click',async()=>{await j('/api/ocean/batch/'+encodeURIComponent(x.job_id)+'/resume',{method:'POST'});renderTasks()});
         card.querySelector('.local-retry')?.addEventListener('click',async()=>{await j('/api/ocean/batch/'+encodeURIComponent(x.job_id)+'/retry',{method:'POST'});renderTasks()});

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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 def test_download_job_backend():
     route=(ROOT/"routes"/"downloads.py").read_text(encoding="utf-8")

tests/test_manual_tasks_v469.py

@@ -0,0 +1,30 @@
+from pathlib import Path
+ROOT=Path(__file__).resolve().parents[1]
+
+def test_version():
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
+
+def test_manual_task_backend_exists():
+    service=(ROOT/"services/manual_tasks.py").read_text(encoding="utf-8")
+    routes=(ROOT/"routes/manual_tasks.py").read_text(encoding="utf-8")
+    assert "class ManualTaskStore" in service
+    assert "VALID_STATUSES" in service
+    assert "/api/sidebar/tasks/manual" in routes
+    assert 'methods=["POST"]' in routes
+    assert 'methods=["PATCH"]' in routes
+    assert 'methods=["DELETE"]' in routes
+
+def test_ui_server_lists_manual_tasks():
+    py=(ROOT/"ui_server.py").read_text(encoding="utf-8")
+    assert "MANUAL_TASK_STORE.list_user" in py
+    assert '"kind":"manual"' in py
+    assert "register_manual_task_routes" in py
+
+def test_frontend_new_task_controls():
+    js=(ROOT/"static/js/app.js").read_text(encoding="utf-8")
+    assert "＋ 新建任务" in js
+    assert "openManualTaskEditor" in js
+    assert "标记完成" in js
+    assert "重新打开" in js
+    assert "manual-delete" in js
+    assert "账号服务器持久化（可跨设备）" 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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 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.8"
+    assert (ROOT / "VERSION").read_text(encoding="utf-8").strip() == "4.6.9"
 
 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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 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.8"
+    assert version == "4.6.9"
     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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 def test_new_source_mappings():
     py=(ROOT/"sidebar_catalog.py").read_text(encoding="utf-8")

tests/test_squid_finalize_v467.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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 def test_ccamlr_and_ommastrephidae_mappings():
     py=(ROOT/"sidebar_catalog.py").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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 def test_assistant_avatar_removed_user_avatar_customizable():
     js=(ROOT/"static"/"js"/"app.js").read_text(encoding="utf-8")

tests/test_unclassified_inventory_v463.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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 def test_backend_unique_classification_and_route():
     py=(ROOT/"routes"/"datasets.py").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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 def test_joint_squid_environment_plan():
     p=plan_unified_query("查询 2002 年 8 月西北太平洋柔鱼记录，并匹配 SST、SSH、CHL")

tests/test_upstream_refresh_retry_v461.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.8"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.9"
 
 def test_probe_returns_status_and_rejects_dead_url():
     py=(ROOT/"routes"/"downloads.py").read_text(encoding="utf-8")

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