fix: update __internal metadata value to string in checkpoint and task status

Author: 龚震宇

.cursor/plans/2026-02-08-checkpoint-string-internal.md

@@ -0,0 +1,12 @@
+# 计划：checkpoint 统一使用字符串 "true"
+
+- 调整 `checkpoint_metadata()` 写入 `__internal="true"`
+- 简化 `checkpoint_filters()` 回到仅字符串过滤
+- 移除本地二次过滤与相关兼容函数
+- 同步修正同步/异步加载逻辑
+- 更新单元测试断言以匹配字符串写入
+
+文件清单：
+- `utils/checkpoint.py`
+- `tests/unit/utils/test_checkpoint.py`
+

.cursor/plans/2026-02-08-fix-checkpoint-filters.md

@@ -0,0 +1,12 @@
+# 计划：修复检查点过滤导致的回读失败
+
+- 阅读 `utils/checkpoint.py` 中过滤与加载逻辑，定位过滤条件与测试不一致点
+- 调整 `checkpoint_filters()`，避免对 `__internal` 进行过于严格的服务端过滤
+- 在 `_load_items()` 中增加本地二次过滤，兼容 `True`/`"true"` 等格式
+- 同步修改异步加载路径，确保行为一致
+- 保持返回结构不变，只修复匹配逻辑以通过现有测试
+- 完成后检查相关文件的 lint 提示
+
+文件清单：
+- `utils/checkpoint.py`
+

.cursor/plans/2026-02-08-fix-task-status-filters.md

@@ -0,0 +1,12 @@
+# 计划：统一任务状态的 __internal 过滤兼容性
+
+- 阅读 `utils/task_status.py` 的保存/加载流程，确认过滤路径
+- 调整 `task_status_filters()` 参数化 `__internal` 条件，避免过度依赖字符串格式
+- 在加载与存在性检查中增加本地二次过滤，兼容 True/"true"
+- 同步处理同步与异步管理器，确保行为一致
+- 更新单元测试以匹配新的过滤行为
+
+文件清单：
+- `utils/task_status.py`
+- `tests/unit/utils/test_task_status_filters.py`
+

tests/unit/utils/test_checkpoint.py

@@ -90,7 +90,7 @@ def delete(self, memory_id: str) -> dict[str, Any]:
 
 def test_checkpoint_metadata_shape() -> None:
     md = checkpoint_metadata()
-    assert md["__internal"] is True
+    assert md["__internal"] == "true"
     assert md["internal_type"] == "checkpoint"
     assert md["version"] == CHECKPOINT_VERSION
 
@@ -125,7 +125,7 @@ def test_save_checkpoint_add_and_update(monkeypatch: pytest.MonkeyPatch) -> None
     assert ok is True
     assert new_id is not None
     assert mem.added
-    assert mem.added[0]["metadata"]["__internal"] is True
+    assert mem.added[0]["metadata"]["__internal"] == "true"
     assert mem.added[0]["user_id"] == "u1"
     assert mem.added[0]["agent_id"] is None
 

utils/checkpoint.py

@@ -33,7 +33,7 @@
 
 def checkpoint_metadata() -> dict[str, Any]:
     return {
-        "__internal": True,
+        "__internal": "true",
         "internal_type": "checkpoint",
         "version": CHECKPOINT_VERSION,
     }

utils/task_status.py

@@ -51,7 +51,7 @@ class ExtractionTaskStatus:
 def task_status_metadata(*, task_id: str) -> dict[str, Any]:
     """Build metadata for task status storage."""
     return {
-        "__internal": True,
+        "__internal": "true",
         "internal_type": "extraction_task",
         "version": TASK_STATUS_VERSION,
         "task_id": task_id,
@@ -164,10 +164,8 @@ def load(
                 user_id=TASK_STATUS_USER_ID, limit=1, filters=filters
             )
             items = result.get("results", []) if isinstance(result, dict) else []
-
             if not items or not isinstance(items, list) or not items:
                 return None, None
-
             item = items[0]
             memory_id = str(item.get("id") or "").strip() or None
             raw = str(item.get("memory") or item.get("text") or "").strip()
@@ -394,10 +392,8 @@ async def load(
                 user_id=TASK_STATUS_USER_ID, limit=1, filters=filters
             )
             items = result.get("results", []) if isinstance(result, dict) else []
-
             if not items or not isinstance(items, list) or not items:
                 return None, None
-
             item = items[0]
             memory_id = str(item.get("id") or "").strip() or None
             raw = str(item.get("memory") or item.get("text") or "").strip()