[FEATURE] Add exact historical Flow state lookup scoped to its UUID

问题场景

在使用 CrewAI 的 Flow 持久化能力时，用户希望通过历史记录中的稳定行 ID 加上 Flow UUID 精确取回某一条历史状态。当前 SQLiteFlowPersistence 只提供 load_state 这类读取活动状态的接口，配合历史列表 API 使用时，列表里的历史记录只携带元数据，拿不到对应行的状态内容，因此无法完成“按 UUID 精确查询历史状态”的需求。

报错原文

[FEATURE] Add exact historical Flow state lookup scoped to its UUID

原因分析

可能原因：代码库中尚不存在按 Flow UUID 限定范围、按行 ID 查询单条历史状态的只读方法。Issue 的验收条件要求：属于其他 Flow UUID 的行不得返回；记录不存在时返回 None；匹配记录需保留存储的 JSON 状态；还要覆盖嵌套 state、缺失 ID、多 Flow 以及最新状态 API 的回归测试。讨论中还提到，历史记录本身只带元数据，所以需要该查询来补齐状态，而底层历史列表 API 当时尚未合入 main。

环境排查

• 确认所用 CrewAI 版本是否已包含 SQLiteFlowPersistence.load_state_from_history。
• 确认 lib/crewai/src/crewai/flow/persistence/sqlite.py 中是否已有对应方法与 JSON 解码逻辑。
• 确认依赖的历史列表 API（#8138 / #8253）是否已合入当前分支。
• 确认 lib/crewai/tests/test_flow_persistence.py 中是否有嵌套状态、缺失 ID、多 Flow 的测试用例。
• Issue 未给出 Python、CUDA、PyTorch、显卡等版本要求，无需据此排查。

解决步骤

1. 先确认依赖状态：查看 #8138 是否已被 #8253 覆盖并合入 main；若未合入，按讨论中的方案在 main 上独立实现，合入后再 rebase。
2. 在 SQLiteFlowPersistence 中新增 load_state_from_history(flow_uuid, record_id)，返回类型标注为 dict[str, Any] | None，与 load_state 保持一致。
3. 查询时用绑定参数同时匹配行 ID 和 Flow UUID，确保不会返回属于其他 Flow 的记录。
4. 处理返回值：记录不存在或 JSON 不是 dict 时返回 None；匹配成功时返回存储的 JSON 状态，沿用现有 JSON 解码约定。
5. 保持范围最小：仅 SQLite 实现，不改动基类接口、不新增只读的模块级变体、不改动当前活动 Flow 状态、不新增历史恢复 API。
6. 在 test_flow_persistence.py 中补充测试：嵌套 state 数据、缺失 ID、多 Flow 隔离，以及 load_state 的回归测试。

验证方法

运行 test_flow_persistence.py 中的新增用例与既有用例，确认：用其他 Flow UUID 查询同一行 ID 时返回 None；不存在的 ID 返回 None；匹配记录返回的 dict 与存储的嵌套 JSON 一致；load_state 行为未发生回归。Issue 说明这些测试不需要调用付费 API。

参考来源

crewAIInc/crewAI #8139

AI 工具推荐

想把多个 AI 模型放在一个入口？

GamsGo AI 集成 ChatGPT、DeepSeek、Gemini、Claude、Midjourney、Veo 等常用模型，适合写作、绘图、视频和日常 AI 工作流。

了解 GamsGo AI

推广链接：通过此链接购买，我可能获得佣金，不影响你的价格。