R3.2.8.6-R1.2 Option A Local Resume Capability Reconciliation

app.py

@@ -305,6 +305,76 @@ def _task_dir(task_id: str) -> Path:
     return Path(_user_workspace) / "tasks" / _safe_key(task_id)
 
 
+def _local_resume_capability(task: dict) -> tuple[bool, str]:
+    """Return whether this HF runtime has the local material required to resume.
+
+    Worker/D1 remains authoritative for the remote task state. This function
+    answers only the local capability question and never changes task/quota
+    state.
+    """
+    task = dict(task or {})
+    task_id = str(task.get("task_id") or "").strip()
+    if not task_id:
+        return False, "task_id_missing"
+
+    task_dir = _task_dir(task_id)
+    request_path = task_dir / "request.json"
+    if not request_path.is_file():
+        return False, "request_missing"
+    try:
+        request_payload = json.loads(request_path.read_text(encoding="utf-8"))
+    except Exception:
+        return False, "request_unreadable"
+    if not isinstance(request_payload, dict):
+        return False, "request_invalid"
+    if str(request_payload.get("task_id") or "").strip() != task_id:
+        return False, "request_task_mismatch"
+
+    request_hash = str(request_payload.get("request_hash") or "").strip().lower()
+    if not re.fullmatch(r"[a-f0-9]{64}", request_hash):
+        return False, "request_hash_invalid"
+    if request_hash != _canonical_request_hash(request_payload):
+        return False, "request_hash_mismatch"
+
+    task_root = task_dir.resolve()
+    for field in ("reference_files", "data_files", "interview_files"):
+        items = request_payload.get(field) or []
+        if not isinstance(items, list):
+            return False, f"{field}_invalid"
+        for item in items:
+            local_path = (task_dir / str(item)).resolve()
+            if task_root not in local_path.parents or not local_path.is_file():
+                return False, "input_missing"
+
+    try:
+        checkpoint_seq = int(task.get("checkpoint_seq") or 0)
+    except (TypeError, ValueError):
+        return False, "checkpoint_seq_invalid"
+    if checkpoint_seq <= 0:
+        return True, "ready"
+
+    expected_stage = str(task.get("checkpoint_stage") or "").strip()
+    try:
+        candidates = sorted((task_dir / "checkpoints").glob(f"checkpoint_{checkpoint_seq:05d}_*.json"))
+    except Exception:
+        candidates = []
+    for candidate in candidates:
+        try:
+            payload = json.loads(candidate.read_text(encoding="utf-8"))
+            if not isinstance(payload, dict):
+                continue
+            if str(payload.get("request_hash") or "").strip().lower() != request_hash:
+                continue
+            if int(payload.get("checkpoint_seq") or 0) != checkpoint_seq:
+                continue
+            if expected_stage and str(payload.get("checkpoint_stage") or "").strip() != expected_stage:
+                continue
+            return True, "ready"
+        except Exception:
+            continue
+    return False, "checkpoint_missing"
+
+
 def _task_preview_path(task_id: str) -> str:
     """Return the unguessable local static preview URL for this task, if any."""
     request_path = _task_dir(task_id) / "request.json"
@@ -532,12 +602,15 @@ def _process_pending_resume() -> None:
     task_id = str(st.session_state.get("sp_pending_resume_task_id") or "").strip()
     if not task_id:
         return
-    if not (_task_dir(task_id) / "request.json").is_file():
+    task = dict(st.session_state.get("sp_generation_task") or {})
+    capable, reason = _local_resume_capability(task)
+    if str(task.get("task_id") or "").strip() != task_id or not capable:
+        logging.warning("[SP_UI] resume_unavailable task_id=%s reason=%s", task_id, reason)
         st.session_state["sp_pending_resume_task_id"] = ""
-        st.session_state["sp_pending_cancel_task_id"] = task_id
+        lang_code = str(st.session_state.get("sp_lang_code") or "zh")
         st.session_state["sp_terminal_notice"] = {
-            "kind": "error",
-            "message": "Local checkpoint/request files are unavailable after runtime replacement; the reserved quota will be released.",
+            "kind": "warning",
+            "message": tr(lang_code, "resume_unavailable_runtime_replaced"),
         }
         st.rerun()
     _launch_executor(task_id, force=True)
@@ -816,7 +889,8 @@ def _render_task_status_once(lang_code: str) -> None:
     _render_checkpoint_preview(task, lang_code)
 
     if status == "resumable":
-        st.warning(tr(lang_code, "checkpoint_warning"))
+        resume_capable, _ = _local_resume_capability(task)
+        st.warning(tr(lang_code, "checkpoint_warning" if resume_capable else "resume_unavailable_runtime_replaced"))
     elif status == "completed":
         output_path = _task_output_path(task)
         if output_path and output_path.is_file():
@@ -914,9 +988,17 @@ def render_workspace_controls(user):
 
 
     if task_status == "resumable":
-        st.warning(tr(lang_code, "checkpoint_warning"))
+        resume_capable, resume_reason = _local_resume_capability(task)
+        if resume_capable:
+            st.warning(tr(lang_code, "checkpoint_warning"))
+        else:
+            logging.warning(
+                "[SP_UI] local_resume_capability_missing task_id=%s reason=%s",
+                str(task.get("task_id") or ""), resume_reason,
+            )
+            st.warning(tr(lang_code, "resume_unavailable_runtime_replaced"))
         colA, colB = st.columns([1, 1])
-        if colA.button(tr(lang_code, "resume"), key="resume_task"):
+        if colA.button(tr(lang_code, "resume"), key="resume_task", disabled=not resume_capable):
             st.session_state["sp_pending_resume_task_id"] = str(task.get("task_id") or "")
             st.rerun()
         if colB.button(tr(lang_code, "clear"), key="clear_task"):

i18n.py

@@ -215,6 +215,7 @@ TEXTS: dict[str, dict[str, str]] = {
         "system_busy_warning": "🚨 有用户正在生成论文",
         "system_busy_info": "💡 预计25–35分钟后可正常使用",
         "checkpoint_warning": "⚠️ 检测到暂停的未完成论文任务。您可以继续原任务，或删除后重新开始。",
+        "resume_unavailable_runtime_replaced": "⚠️ 检测到暂停的未完成论文任务，但当前运行环境缺少继续所需的本地请求或断点文件。为避免错误恢复，继续按钮已禁用；如需释放本任务并重新开始，请明确点击“删除并重新开始”。",
         "resume": "🔄 继续原任务",
         "clear": "🗑️ 删除并重新开始",
         "cancel_generation": "⛔ 取消生成",
@@ -385,6 +386,7 @@ TEXTS: dict[str, dict[str, str]] = {
         "system_busy_warning": "🚨 Another user is generating a paper",
         "system_busy_info": "💡 The system is expected to be available in 25–35 minutes",
         "checkpoint_warning": "⚠️ A paused unfinished paper task was detected. You can continue it or delete it and start again.",
+        "resume_unavailable_runtime_replaced": "⚠️ A paused unfinished paper task was detected, but this runtime no longer has the local request or checkpoint files required to continue it. Resume has been disabled to prevent an unsafe recovery. To release this task and start again, explicitly choose ‘Delete and Start Again’.",
         "resume": "🔄 Continue Previous Task",
         "clear": "🗑️ Delete and Start Again",
         "cancel_generation": "⛔ Cancel Generation",
@@ -555,6 +557,7 @@ TEXTS: dict[str, dict[str, str]] = {
         "system_busy_warning": "🚨 Другой пользователь формирует статью",
         "system_busy_info": "💡 Ожидаемое время доступности — через 25–35 минут",
         "checkpoint_warning": "⚠️ Обнаружена приостановленная незавершённая задача. Вы можете продолжить её или удалить и начать заново.",
+        "resume_unavailable_runtime_replaced": "⚠️ Обнаружена приостановленная незавершённая задача, но в текущей среде выполнения отсутствуют локальный файл запроса или контрольная точка, необходимые для продолжения. Чтобы избежать некорректного восстановления, кнопка продолжения отключена. Для освобождения задачи и нового запуска явно выберите «Удалить и начать заново».",
         "resume": "🔄 Продолжить предыдущую задачу",
         "clear": "🗑️ Удалить и начать заново",
         "cancel_generation": "⛔ Отменить генерацию",
@@ -725,6 +728,7 @@ TEXTS: dict[str, dict[str, str]] = {
         "system_busy_warning": "🚨 Басқа пайдаланушы мақала дайындап жатыр",
         "system_busy_info": "💡 Жүйе шамамен 25–35 минуттан кейін қолжетімді болады",
         "checkpoint_warning": "⚠️ Аяқталмаған, уақытша тоқтатылған тапсырма анықталды. Оны жалғастыруға немесе өшіріп, қайта бастауға болады.",
+        "resume_unavailable_runtime_replaced": "⚠️ Уақытша тоқтатылған аяқталмаған тапсырма анықталды, бірақ ағымдағы іске қосу ортасында оны жалғастыруға қажет жергілікті сұрау немесе бақылау нүктесі файлдары жоқ. Қате қалпына келтіруге жол бермеу үшін жалғастыру түймесі өшірілді. Тапсырманы босатып, қайта бастау үшін «Өшіріп, қайта бастау» әрекетін нақты таңдаңыз.",
         "resume": "🔄 Алдыңғы тапсырманы жалғастыру",
         "clear": "🗑️ Өшіріп, қайта бастау",
         "cancel_generation": "⛔ Генерацияны тоқтату",