Checklist

• 我已经搜索过相关问题，但没有得到预期的帮助。
• 最新版本中该错误尚未修复。
• 请注意，如果您提交的Bug描述缺少相应的环境信息和最小可复现的demo，我们将很难复现和解决该问题，从而降低收到反馈的可能性，甚至该问题将被关闭。

🐞 问题详细描述

DB 完全宕机时 DbDataStore.write 吞掉 create 异常，write 不向外抛，CacheBackedDataStore 继续刷新 Redis，出现"DB 未写入但 Redis 被刷新"的脏缓存。

根因
DbDataStore.write（db_data_store.py:105-136）的设计意图是"先 create，主键冲突则回退 update"，用 try/except Exception 包裹 create。但 except 分支吞掉所有异常（包括非主键冲突的 DB 宕机异常），无条件走 get+update 回退路径。当 DB 完全宕机时：

1. create 抛 RuntimeError("DB down") → 被 except Exception 捕获（line 120）
2. get 返回 None（DB 不可用）
3. update 在 store 空时返回 None，不抛错（line 125）
4. write 正常返回，不向上传播
5. CacheBackedDataStore.write（cache_backed_data_store.py:42-52）继续执行 cache.set_json，Redis 被刷新

触发条件

• runtime_db_enabled=True
• DB handler 的 create 抛任意异常（连接断开、权限错误、磁盘满等，不止主键冲突）
• 典型场景：DB 主机宕机、网络分区、连接池耗尽

影响范围

• 数据一致性：DB 无记录但 Redis 有缓存，出现"幻读"——调用方读到数据但 DB 兜底失效
• 持久化目标落空：串讲文档核心目标"Redis 故障时业务状态可从 DB 恢复"无法达成，因为 DB 根本没写入
• 故障传播失效：运维无法通过 write 失败感知 DB 故障，延迟发现
• 触发概率：中（DB 完全宕机是 P0 故障，但本应"失败可见"而非"静默成功"）

代码位置

• db_data_store.py:120 except Exception as e: logger.debug(...) ← 吞异常过宽
• db_data_store.py:123-135 回退路径无写入结果校验
• cache_backed_data_store.py:42 await self._db.write(...) 后无条件执行 line 52 cache.set_json

复现证据（TC-R01）

self.db_handler.create = _always_fail_create  # create 永远抛
self.db_handler.get = _always_return_none_get
self.db_handler.update = _always_return_none_update
await self.adapter.put("conv-r1", {"v": 1})  # 不抛
self.assertNotIn(("session_task", "conv-r1"), self.db_handler._store)  # DB 无记录
self.assertEqual(len(self.cache.set_calls), 1)  # cache 被刷新 ← 脏刷新

修复建议

1. 区分异常类型：create 失败时仅当异常是主键冲突（IntegrityError/UniqueViolation）才回退 update，其他异常向上抛
2. 或在回退路径增加写入结果校验：if update 返回 None 且 get 返回 None: raise RuntimeError("DB write failed: record not created")
3. CacheBackedDataStore.write 可增加 db.write 返回值校验，确保 DB 写入成功后才刷 cache

详细的环境信息描述

单机环境本地部署

其他辅助信息

代码片段，agent-runtime\applications\a2a_service\common\db_data_store.py

        try:
            await self._db.create(
                self._table,
                {
                    "state_domain": namespace,
                    "state_key": key,
                    "payload": value,
                    "version": 1,
                    "state_metadata": metadata,
                    "updated_at": now,
                    "expire_at": expire_at,
                },
            )
            logger.debug("[DbDataStore] write_insert namespace=%s key=%s", namespace, key)
            return
        except Exception as e:
            logger.debug("[DbDataStore] create_failed fallback to update: %s", e)

版本信息

感谢您的贡献 🎉!