Feat/20260706 visualized card

README.md

@@ -630,6 +630,8 @@ Gateway-generated follow-up suggestions now normalize both plain-string model ou
 
 Interrupted first-turn runs still persist a fallback conversation title, so stopping a streaming response does not leave the thread as "Untitled" after refresh.
 
+In the Web UI, completed assistant turns can be branched into a new main conversation. The new thread starts from that turn's checkpoint. Because workspace files are not checkpointed, the branch only receives a best-effort copy of the current workspace when you branch from the latest turn; branching from an older turn keeps just the restored message history so the branch never inherits files that were created in a later part of the conversation.
+
 ```
 # Paths inside the sandbox container
 /mnt/skills/public

README_zh.md

@@ -484,6 +484,8 @@ Tools 也是同样的思路。DeerFlow 自带一组核心工具：网页搜索
 
 Gateway 生成后续建议时，现在会先把普通字符串输出和 block/list 风格的富文本内容统一归一化，再去解析 JSON 数组响应，因此不同 provider 的内容包装方式不会再悄悄把建议吞掉。
 
+Web UI 支持从已完成的 assistant 回复分叉出一个新的主对话。新 thread 会从该回复对应的 checkpoint 开始，并尽力复制当前 thread 的工作区文件。
+
 ```text
 # sandbox 容器内的路径
 /mnt/skills/public

backend/app/gateway/deps.py

@@ -19,6 +19,7 @@
 
 import asyncio
 import logging
+import os
 from collections.abc import AsyncGenerator, Callable
 from contextlib import AsyncExitStack, asynccontextmanager
 from typing import TYPE_CHECKING, TypeVar, cast
@@ -45,6 +46,27 @@
 _RUN_DRAIN_TIMEOUT_SECONDS = 5.0
 
 
+def _enforce_postgres_for_multi_worker(config: AppConfig) -> None:
+    """Refuse to start when GATEWAY_WORKERS > 1 and the DB backend is not Postgres.
+
+    SQLite write-locks cannot support concurrent multi-process access.
+    This gate runs once at startup before any persistence engine is
+    initialised so the error message is clear and the process exits
+    immediately.
+    """
+    try:
+        workers = int(os.environ.get("GATEWAY_WORKERS", "1"))
+    except (TypeError, ValueError):
+        workers = 1
+
+    if workers <= 1:
+        return
+
+    backend = getattr(config.database, "backend", None)
+    if backend != "postgres":
+        raise SystemExit(f"GATEWAY_WORKERS={workers} requires database.backend='postgres', but database.backend is '{backend}'. SQLite cannot support concurrent multi-process access. Set GATEWAY_WORKERS=1 or switch to Postgres.")
+
+
 async def _drain_inflight_runs(run_manager: RunManager) -> None:
     """Drain in-flight runs before the checkpointer is torn down (issue #3373).
 
@@ -209,6 +231,12 @@ async def langgraph_runtime(app: FastAPI, startup_config: AppConfig) -> AsyncGen
     from deerflow.runtime.checkpointer.async_provider import make_checkpointer
     from deerflow.runtime.events.store import make_run_event_store
 
+    # ------------------------------------------------------------------
+    # Multi-worker safety gate: reject SQLite when GATEWAY_WORKERS > 1.
+    # SQLite write-locks cannot support concurrent multi-process access.
+    # ------------------------------------------------------------------
+    _enforce_postgres_for_multi_worker(startup_config)
+
     async with AsyncExitStack() as stack:
         config = startup_config
 

backend/app/gateway/routers/memory.py

@@ -131,6 +131,11 @@ class MemoryConfigResponse(BaseModel):
         ...,
         description="Token ceiling for guaranteed-category facts (displaces regular lines in the common case; additive only when guaranteed alone overflows max_injection_tokens)",
     )
+    staleness_review_enabled: bool = Field(..., description="Whether staleness review is enabled for aged facts")
+    staleness_age_days: int = Field(..., description="Facts older than this many days are candidates for staleness review")
+    staleness_min_candidates: int = Field(..., description="Minimum stale facts required to trigger a review cycle")
+    staleness_max_removals_per_cycle: int = Field(..., description="Maximum number of facts staleness review can remove per cycle")
+    staleness_protected_categories: list[str] = Field(..., description="Fact categories exempt from staleness review")
 
 
 class MemoryStatusResponse(BaseModel):
@@ -360,6 +365,11 @@ async def get_memory_config_endpoint() -> MemoryConfigResponse:
         token_counting=config.token_counting,
         guaranteed_categories=config.guaranteed_categories,
         guaranteed_token_budget=config.guaranteed_token_budget,
+        staleness_review_enabled=config.staleness_review_enabled,
+        staleness_age_days=config.staleness_age_days,
+        staleness_min_candidates=config.staleness_min_candidates,
+        staleness_max_removals_per_cycle=config.staleness_max_removals_per_cycle,
+        staleness_protected_categories=config.staleness_protected_categories,
     )
 
 
@@ -391,6 +401,11 @@ async def get_memory_status(http_request: Request) -> MemoryStatusResponse:
             token_counting=config.token_counting,
             guaranteed_categories=config.guaranteed_categories,
             guaranteed_token_budget=config.guaranteed_token_budget,
+            staleness_review_enabled=config.staleness_review_enabled,
+            staleness_age_days=config.staleness_age_days,
+            staleness_min_candidates=config.staleness_min_candidates,
+            staleness_max_removals_per_cycle=config.staleness_max_removals_per_cycle,
+            staleness_protected_categories=config.staleness_protected_categories,
         ),
         data=MemoryResponse(**memory_data),
     )