From 87fcbc5bfb0152d483cf823c8016131dec3b4761 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=90=89=E9=91=AB=E5=8D=87?= Date: Tue, 19 May 2026 16:28:10 +0800 Subject: [PATCH 1/3] =?UTF-8?q?chore:=20vite=20=E6=9E=84=E5=BB=BA=E4=BA=A7?= =?UTF-8?q?=E7=89=A9=E4=BD=BF=E7=94=A8=E7=9B=B8=E5=AF=B9=E8=B7=AF=E5=BE=84?= =?UTF-8?q?=20(base:=20"./")?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-Authored-By: Claude Opus 4.7 --- frontend-web/vite.config.ts | 15 ++++++++------- 1 file changed, 8 insertions(+), 7 deletions(-) diff --git a/frontend-web/vite.config.ts b/frontend-web/vite.config.ts index b560c6d7..8d6e4335 100644 --- a/frontend-web/vite.config.ts +++ b/frontend-web/vite.config.ts @@ -1,13 +1,13 @@ -import path from "node:path"; -import { fileURLToPath } from "node:url"; - -import react from "@vitejs/plugin-react"; -import { defineConfig } from "vite"; +import path from "node:path"; +import { fileURLToPath } from "node:url"; + +import react from "@vitejs/plugin-react"; +import { defineConfig } from "vite"; const rootDir = fileURLToPath(new URL(".", import.meta.url)); -export default defineConfig({ - plugins: [react()], +export default defineConfig({ + plugins: [react()], resolve: { alias: [ { @@ -32,6 +32,7 @@ export default defineConfig({ }, ], }, + "base":"./", server: { port: 5173, }, From 028c5a34e664d34e7ae8b661f5056177b63159d5 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=90=89=E9=91=AB=E5=8D=87?= Date: Tue, 19 May 2026 17:22:17 +0800 Subject: [PATCH 2/3] =?UTF-8?q?fix:=20=E9=80=9F=E5=BA=A6=E8=83=B6=E5=9B=8A?= =?UTF-8?q?=E6=AF=8F=E8=BD=AE=E5=8F=AA=E6=98=BE=E7=A4=BA=E4=B8=80=E6=AC=A1?= =?UTF-8?q?=20+=20=E6=8A=80=E8=83=BD=E8=B0=83=E7=94=A8=E6=8C=89=20run=20?= =?UTF-8?q?=E5=90=88=E5=B9=B6=E7=BB=9F=E8=AE=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 速度胶囊：原本每条 AI 消息都渲染，agentic 多轮 LLM 调用会出现多个胶囊。改为只在每轮 turn-final 消息（下一条 human 之前的最后一条 AI 消息）显示。 技能统计：tool_call_metrics 改为按 (run_id, skill_name) upsert 合并——同一 run 内同一技能的多次调用/重试合并为一行；任一成功即记成功，全部失败则记一行 error 并累积所有报错信息；非技能调用不受影响。 Co-Authored-By: Claude Opus 4.7 --- .../messages/message-token-usage.tsx | 8 +- .../workspace/messages/use-message-metrics.ts | 27 ++++ offline-backend-20260512/backend/CLAUDE.md | 2 +- .../persistence/tool_metrics/__init__.py | 8 + .../deerflow/persistence/tool_metrics/sql.py | 139 ++++++++++++++++-- 5 files changed, 167 insertions(+), 17 deletions(-) diff --git a/frontend-web/src/components/workspace/messages/message-token-usage.tsx b/frontend-web/src/components/workspace/messages/message-token-usage.tsx index 094a2938..16019b2c 100644 --- a/frontend-web/src/components/workspace/messages/message-token-usage.tsx +++ b/frontend-web/src/components/workspace/messages/message-token-usage.tsx @@ -88,7 +88,13 @@ export function MessageTokenUsage({ // otherwise wait until usage arrives so the bar doesn't render on its own. const usage = getUsageMetadata(message); const showUsage = enabled && !isLoading && Boolean(usage); - const showSpeed = speedEnabled && resolvedMetric !== undefined && resolvedMetric.durationMs > 0; + // The speed pill is shown once per turn — only on the turn-final AI message + // — so a turn with several LLM calls no longer renders a pill per call. + const showSpeed = + speedEnabled && + resolvedMetric !== undefined && + resolvedMetric.durationMs > 0 && + resolvedMetric.isTurnFinal; if (!showUsage && !showSpeed) { return null; diff --git a/frontend-web/src/components/workspace/messages/use-message-metrics.ts b/frontend-web/src/components/workspace/messages/use-message-metrics.ts index 42224fbe..5b201418 100644 --- a/frontend-web/src/components/workspace/messages/use-message-metrics.ts +++ b/frontend-web/src/components/workspace/messages/use-message-metrics.ts @@ -36,6 +36,13 @@ export interface MessageMetric { * only to add a "~" prefix when the value is approximate. */ fromUsage: boolean; + /** + * True iff this is the turn-final AI message — the last AI message before + * the next human message. An agentic turn makes several LLM calls, each its + * own AI message; the speed pill is shown only on the turn-final one so a + * turn renders a single pill instead of one per call. + */ + isTurnFinal: boolean; } type Sample = { at: number; chars: number }; @@ -161,6 +168,25 @@ export function useMessageMetrics( return () => window.clearInterval(interval); }, [isLoading]); + // Identify the turn-final AI message of each turn — the last AI message + // (with a recorded metric) before the next human message. Only these show + // the speed pill, collapsing a multi-LLM-call turn to a single pill. + const turnFinalIds = new Set(); + let pendingTurnFinal: string | null = null; + for (let i = 0; i < messages.length; i++) { + const message = messages[i]; + if (!message) continue; + if (message.type === "human") { + if (pendingTurnFinal) turnFinalIds.add(pendingTurnFinal); + pendingTurnFinal = null; + continue; + } + if (isAiMessage(message) && timingRef.current.has(getMessageId(message, i))) { + pendingTurnFinal = getMessageId(message, i); + } + } + if (pendingTurnFinal) turnFinalIds.add(pendingTurnFinal); + // Build the snapshot map. We compute on every render so consumers see the // freshest duration; the underlying timing storage is the source of truth. const out = new Map(); @@ -212,6 +238,7 @@ export function useMessageMetrics( durationMs, isActive, fromUsage, + isTurnFinal: turnFinalIds.has(id), }); } diff --git a/offline-backend-20260512/backend/CLAUDE.md b/offline-backend-20260512/backend/CLAUDE.md index 3cdf716d..c0d2564d 100644 --- a/offline-backend-20260512/backend/CLAUDE.md +++ b/offline-backend-20260512/backend/CLAUDE.md @@ -173,7 +173,7 @@ Lead-agent middlewares are assembled in strict append order across `packages/har 16. **SubagentLimitMiddleware** - Truncates excess `task` tool calls from model response to enforce `MAX_CONCURRENT_SUBAGENTS` limit (optional, if `subagent_enabled`) 17. **LoopDetectionMiddleware** - Detects repeated tool-call loops; hard-stop responses clear both structured `tool_calls` and raw provider tool-call metadata before forcing a final text answer 18. **ClarificationMiddleware** - Intercepts `ask_clarification` tool calls, interrupts via `Command(goto=END)` (must be last) -8a. **ToolMetricsMiddleware** - Appended immediately after `ToolErrorHandlingMiddleware` in `_build_runtime_middlewares`, so it sits *deepest* in the `wrap_tool_call` chain. Records one `tool_call_metrics` row per tool/skill/MCP invocation — timing duration and bucketing failures into a coarse `error_category` (rate_limited / ip_blocked / auth_error / timeout / network_error / not_found / empty_result / tool_error). It catches both raised exceptions (before #8 converts them) and *self-handled* errors returned as error `ToolMessage`s (search tools that swallow HTTP 429/403). It also captures the targeted Agent Skill into `tool_call_metrics.skill_name`: the lead agent invokes a skill by `read_file`-ing its `/mnt/skills///SKILL.md` path (per the `` prompt block — there is no dedicated "use skill" tool), so `skill_name` is recovered by scanning every tool call's string arguments for the `skills/{public,custom}/{name}/` path shape (`_SKILL_PATH_RE`), plus the explicit `name` argument of `skill_view`/`skill_manage`/`skill_archive`. `skill_view`-specific success detection handles its swallowed failures (`Skill 'x' not found.` returned as a plain string rather than raised). Regression coverage: `tests/test_tool_metrics_middleware.py`. Writes are best-effort fire-and-forget. Surfaced by the admin `GET /api/admin/tool-metrics` router (which has a `kind=skill` filter and a per-skill `/summary` breakdown). +8a. **ToolMetricsMiddleware** - Appended immediately after `ToolErrorHandlingMiddleware` in `_build_runtime_middlewares`, so it sits *deepest* in the `wrap_tool_call` chain. Records one `tool_call_metrics` row per tool/skill/MCP invocation — timing duration and bucketing failures into a coarse `error_category` (rate_limited / ip_blocked / auth_error / timeout / network_error / not_found / empty_result / tool_error). It catches both raised exceptions (before #8 converts them) and *self-handled* errors returned as error `ToolMessage`s (search tools that swallow HTTP 429/403). It also captures the targeted Agent Skill into `tool_call_metrics.skill_name`: the lead agent invokes a skill by `read_file`-ing its `/mnt/skills///SKILL.md` path (per the `` prompt block — there is no dedicated "use skill" tool), so `skill_name` is recovered by scanning every tool call's string arguments for the `skills/{public,custom}/{name}/` path shape (`_SKILL_PATH_RE`), plus the explicit `name` argument of `skill_view`/`skill_manage`/`skill_archive`. `skill_view`-specific success detection handles its swallowed failures (`Skill 'x' not found.` returned as a plain string rather than raised). Regression coverage: `tests/test_tool_metrics_middleware.py`. Writes are best-effort fire-and-forget. **Per-run skill merging**: `SqlToolMetricsStore.record` upserts skill rows by `(run_id, skill_name)` instead of inserting one row per call — a skill touched by several tool calls / retries inside one run collapses to a single row. Any success in the run wins (a skill that failed then finally succeeded is recorded as one `success`); a skill that only ever failed yields one `error` row whose `error_message` accumulates every attempt's message; durations are summed. Non-skill tool calls, and skill calls with no `run_id`, keep one row each. The read→merge→write is guarded by a per-event-loop `asyncio.Lock`. Surfaced by the admin `GET /api/admin/tool-metrics` router (which has a `kind=skill` filter and a per-skill `/summary` breakdown). 9. **PromptPrefixMiddleware** - Injects the admin-configured prompt prefix into the model request only. The prefix is tagged onto the first human message's `additional_kwargs['prompt_prefix']` by the Gateway (`app.gateway.services`) and prepended to content here at call time, so the persisted/displayed message stays prefix-free 10. **SummarizationMiddleware** - Context reduction when approaching token limits (optional, if enabled) 11. **TodoListMiddleware** - Task tracking with `write_todos` tool (optional, if plan_mode) diff --git a/offline-backend-20260512/backend/packages/harness/deerflow/persistence/tool_metrics/__init__.py b/offline-backend-20260512/backend/packages/harness/deerflow/persistence/tool_metrics/__init__.py index 1642d21e..afaba32a 100644 --- a/offline-backend-20260512/backend/packages/harness/deerflow/persistence/tool_metrics/__init__.py +++ b/offline-backend-20260512/backend/packages/harness/deerflow/persistence/tool_metrics/__init__.py @@ -5,6 +5,14 @@ writes one row recording duration and outcome. Failures are bucketed into a coarse ``error_category`` (rate_limited / ip_blocked / auth_error / timeout / network_error / not_found / empty_result / tool_error) so administrators can spot retrieval outages, blocked IPs, and quota problems at a glance. + +**Skill-call merging**: a skill is often touched by several tool calls inside +one run (read ``SKILL.md``, run a script, retry after a failure). Rather than +one row per call, ``SqlToolMetricsStore.record`` upserts a single row per +``(run_id, skill_name)``: any success in the run wins (a skill that failed then +finally succeeded is recorded as one success), and a skill that only ever +failed yields one ``error`` row whose ``error_message`` accumulates every +attempt's message. Non-skill tool calls keep one row each. """ from deerflow.persistence.tool_metrics.base import ToolMetricRecord, ToolMetricsStore diff --git a/offline-backend-20260512/backend/packages/harness/deerflow/persistence/tool_metrics/sql.py b/offline-backend-20260512/backend/packages/harness/deerflow/persistence/tool_metrics/sql.py index 5f1be7a5..ebb84381 100644 --- a/offline-backend-20260512/backend/packages/harness/deerflow/persistence/tool_metrics/sql.py +++ b/offline-backend-20260512/backend/packages/harness/deerflow/persistence/tool_metrics/sql.py @@ -2,6 +2,7 @@ from __future__ import annotations +import asyncio import logging from collections.abc import AsyncIterator from datetime import UTC, datetime @@ -15,11 +16,99 @@ from deerflow.persistence.tool_metrics.model import ToolCallMetricRow logger = logging.getLogger(__name__) +# Separator joining every failed attempt's message inside one merged skill row. +_ERROR_SEP = "\n--- \n" +# Hard cap on the accumulated ``error_message`` of a merged row. +_MERGED_ERROR_LIMIT = 2000 + +# A single skill invocation often spans several tool calls (read SKILL.md, run +# a script, ...), and the model may retry a skill within the same run. Those +# fire-and-forget writes can interleave on the event loop, so the read → merge → +# write of a skill row is guarded by a lock. ``asyncio.Lock`` binds to the loop +# it is used on; the lock is therefore (re)created whenever the running loop +# changes (the Gateway keeps one persistent loop, while the ``asyncio.run`` +# fallback path spins up a throwaway loop per call — already serialized). +_merge_lock: asyncio.Lock | None = None +_merge_lock_loop: object = None + + +def _skill_merge_lock() -> asyncio.Lock: + global _merge_lock, _merge_lock_loop + loop = asyncio.get_running_loop() + if _merge_lock is None or _merge_lock_loop is not loop: + _merge_lock = asyncio.Lock() + _merge_lock_loop = loop + return _merge_lock + def _normalize_created_at(value: datetime) -> datetime: return value if value.tzinfo else value.replace(tzinfo=UTC) +def _merge_error_messages(existing: str | None, new: str | None) -> str | None: + """Append a failed attempt's message to the accumulated error text. + + All failures are kept ("都统计下来"), separated and capped at + :data:`_MERGED_ERROR_LIMIT` characters. + """ + new = (new or "").strip() + if not new: + return existing + existing = (existing or "").strip() + if not existing: + return new + if new in existing: + # Identical retry failure — no point storing the same line twice. + return existing + combined = existing + _ERROR_SEP + new + if len(combined) > _MERGED_ERROR_LIMIT: + combined = combined[: _MERGED_ERROR_LIMIT - 3] + "..." + return combined + + +def _merge_skill_row(existing: ToolCallMetricRow, metric: ToolMetricRecord) -> None: + """Fold another same-run, same-skill call into an existing metric row. + + Outcome rules: + - any success in the run -> the row becomes a single ``success`` and earlier + failures are dropped ("先报错、最后成功 -> 记一次成功"); + - all calls failed -> a single ``error`` row whose ``error_message`` + accumulates every attempt's message ("一直报错 -> 记一次，报错信息都统计下来"). + """ + existing.duration_ms = (existing.duration_ms or 0) + (metric.duration_ms or 0) + if metric.status == "success": + if existing.status != "success": + existing.status = "success" + existing.error_category = None + existing.error_message = None + return + # metric.status == "error" + if existing.status == "success": + # The skill already succeeded once this run — keep that outcome. + return + existing.status = "error" + if metric.error_category: + existing.error_category = metric.error_category + existing.error_message = _merge_error_messages(existing.error_message, metric.error_message) + + +def _row_from_metric(metric: ToolMetricRecord) -> ToolCallMetricRow: + return ToolCallMetricRow( + id=metric.id, + created_at=_normalize_created_at(metric.created_at), + user_id=metric.user_id, + thread_id=metric.thread_id, + run_id=metric.run_id, + agent_name=metric.agent_name, + tool_name=metric.tool_name, + skill_name=metric.skill_name, + duration_ms=metric.duration_ms, + status=metric.status, + error_category=metric.error_category, + error_message=metric.error_message, + ) + + class SqlToolMetricsStore(ToolMetricsStore): """SQLite/Postgres/MySQL-backed implementation; writes are fire-and-forget.""" @@ -27,28 +116,48 @@ class SqlToolMetricsStore(ToolMetricsStore): self._sf = session_factory async def record(self, metric: ToolMetricRecord) -> None: - row = ToolCallMetricRow( - id=metric.id, - created_at=_normalize_created_at(metric.created_at), - user_id=metric.user_id, - thread_id=metric.thread_id, - run_id=metric.run_id, - agent_name=metric.agent_name, - tool_name=metric.tool_name, - skill_name=metric.skill_name, - duration_ms=metric.duration_ms, - status=metric.status, - error_category=metric.error_category, - error_message=metric.error_message, - ) + # Skill calls are merged per run: the model may touch one skill across + # several tool calls / retries, and the admin wants a single row per + # (run, skill) instead of one per call. Non-skill tool calls, and skill + # calls with no run_id, fall back to a plain insert. + if metric.skill_name and metric.run_id: + await self._record_skill_merged(metric) + return try: async with self._sf() as session: - session.add(row) + session.add(_row_from_metric(metric)) await session.commit() except Exception: # Metrics are best-effort; never surface a write failure to the runtime. logger.warning("Failed to persist tool_call_metrics row %s", metric.id, exc_info=True) + async def _record_skill_merged(self, metric: ToolMetricRecord) -> None: + """Upsert a per-(run, skill) row, folding repeated calls into one.""" + try: + async with _skill_merge_lock(): + async with self._sf() as session: + existing = await session.scalar( + select(ToolCallMetricRow) + .where( + ToolCallMetricRow.run_id == metric.run_id, + ToolCallMetricRow.skill_name == metric.skill_name, + ) + .order_by(ToolCallMetricRow.created_at) + .limit(1) + ) + if existing is None: + session.add(_row_from_metric(metric)) + else: + _merge_skill_row(existing, metric) + await session.commit() + except Exception: + logger.warning( + "Failed to merge tool_call_metrics for skill %s (run %s)", + metric.skill_name, + metric.run_id, + exc_info=True, + ) + def _apply_filters(self, stmt, query: ToolMetricsQuery): if query.user_id: stmt = stmt.where(ToolCallMetricRow.user_id == query.user_id) From bf34b7df4ee57b02e7bbbdda594ea8e168c35655 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=90=89=E9=91=AB=E5=8D=87?= Date: Tue, 19 May 2026 17:22:27 +0800 Subject: [PATCH 3/3] =?UTF-8?q?fix:=20=E4=BF=AE=E5=A4=8D=20Memory=20V2=20?= =?UTF-8?q?=E5=90=88=E5=B9=B6=E5=AF=BC=E8=87=B4=E7=9A=84=E5=90=AF=E5=8A=A8?= =?UTF-8?q?=E5=B4=A9=E6=BA=83?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit master 的 Memory V2 重构删除了 memory/updater.py，admin_users.py 仍从中导入 get_memory_data 导致启动 ImportError。改用 BuiltinFileProvider 读取 V2 的 USER.md / 各 agent MEMORY.md；前端 MemoryBucketView 同步改为渲染 V2 条目列表。 Co-Authored-By: Claude Opus 4.7 --- .../src/pages/AdminUserActivityPage.tsx | 73 ++++++------------- .../app/gateway/routers/admin_users.py | 26 +++++-- 2 files changed, 43 insertions(+), 56 deletions(-) diff --git a/frontend-web/src/pages/AdminUserActivityPage.tsx b/frontend-web/src/pages/AdminUserActivityPage.tsx index 6fe20519..ac22c7d2 100644 --- a/frontend-web/src/pages/AdminUserActivityPage.tsx +++ b/frontend-web/src/pages/AdminUserActivityPage.tsx @@ -71,67 +71,38 @@ function MessageRow({ message }: { message: AdminMessage }) { ); } -/** Render one memory bucket: context summaries + facts. */ +/** Render one Memory V2 bucket: a flat list of USER.md / MEMORY.md entries. */ function MemoryBucketView({ bucket }: { bucket: AdminMemoryBucket }) { - const data = bucket.data as { - user?: Record; - history?: Record; - facts?: Array<{ content?: string; category?: string; confidence?: number }>; - }; - const sections: Array<[string, string]> = []; - const labels: Record = { - workContext: "工作背景", - personalContext: "个人背景", - topOfMind: "近期关注", - recentMonths: "近几个月", - earlierContext: "更早记录", - longTermBackground: "长期背景", - }; - for (const group of [data.user, data.history]) { - for (const [key, value] of Object.entries(group ?? {})) { - const summary = value?.summary?.trim(); - if (summary) sections.push([labels[key] ?? key, summary]); - } - } - const facts = (data.facts ?? []).filter((f) => f.content?.trim()); + const raw = (bucket.data as { entries?: unknown }).entries; + const entries = Array.isArray(raw) + ? raw.filter( + (e): e is string => typeof e === "string" && e.trim().length > 0, + ) + : []; return (
- {bucket.name === "global" ? "全局记忆" : `Agent: ${bucket.name}`} + {bucket.name === "global" ? "用户画像" : `Agent: ${bucket.name}`} + {entries.length > 0 && ( + + {entries.length} 条 + + )}
- {sections.length === 0 && facts.length === 0 && ( + {entries.length === 0 ? (

该记忆库暂无内容。

- )} - {sections.length > 0 && ( -
- {sections.map(([label, summary]) => ( -
- {label} -

{summary}

-
+ ) : ( +
    + {entries.map((entry, i) => ( +
  • + · + {entry} +
    • ))} -
- )} - {facts.length > 0 && ( -
- 事实记录（{facts.length}） -
    - {facts.map((fact, i) => ( -
  • - · - {fact.content} - {fact.category && ( - - {fact.category} - - )} -
    • - ))} -
-
+ )}
); diff --git a/offline-backend-20260512/backend/app/gateway/routers/admin_users.py b/offline-backend-20260512/backend/app/gateway/routers/admin_users.py index 68e80aca..9e022a37 100644 --- a/offline-backend-20260512/backend/app/gateway/routers/admin_users.py +++ b/offline-backend-20260512/backend/app/gateway/routers/admin_users.py @@ -23,7 +23,7 @@ from app.gateway.deps import ( get_current_user_from_request, get_thread_store, ) -from deerflow.agents.memory.updater import get_memory_data +from deerflow.agents.memory import BuiltinFileProvider from deerflow.config.agents_config import AGENT_NAME_PATTERN from deerflow.config.paths import get_paths from deerflow.runtime import serialize_channel_values @@ -136,24 +136,40 @@ class AdminMemoryResponse(BaseModel): buckets: list[AdminMemoryBucket] = Field(default_factory=list) +def _read_memory_bucket(user_id: str, agent_id: str | None) -> dict: + """Read one Memory V2 file into a JSON-able ``{"entries": [...]}`` dict. + + ``agent_id is None`` -> the user's ``USER.md`` (profile, cross-agent); + otherwise that agent's ``MEMORY.md`` (per-agent working notes). + """ + provider = BuiltinFileProvider() + provider.initialize(user_id=user_id, agent_id=agent_id) + target = "user" if agent_id is None else "memory" + return {"entries": provider.read(target)} + + @router.get("/{user_id}/memory", response_model=AdminMemoryResponse) async def get_user_memory(user_id: str, request: Request) -> AdminMemoryResponse: - """Return every memory bucket (global + per-agent) for one user.""" + """Return every memory bucket for one user. + + Memory V2 layout: the ``global`` bucket is ``USER.md`` (user profile); + each per-agent bucket is that agent's ``MEMORY.md`` working notes. + """ await _require_admin(request) buckets: list[AdminMemoryBucket] = [ - AdminMemoryBucket(name="global", data=get_memory_data(None, user_id=user_id)) + AdminMemoryBucket(name="global", data=_read_memory_bucket(user_id, None)) ] agents_root = get_paths().user_dir(user_id) / "agents" if agents_root.is_dir(): for entry in sorted(agents_root.iterdir(), key=lambda p: p.name.lower()): - if not entry.is_dir() or not (entry / "memory.json").exists(): + if not entry.is_dir() or not (entry / "MEMORY.md").exists(): continue if not AGENT_NAME_PATTERN.match(entry.name): continue try: - data = get_memory_data(entry.name, user_id=user_id) + data = _read_memory_bucket(user_id, entry.name) except Exception: logger.warning("Failed to read memory bucket %s for user", entry.name) continue