From cf717a5d493d96b7ecac4e2b17a8eed160d41977 Mon Sep 17 00:00:00 2001 From: Lyon <88232613+pikasTech@users.noreply.github.com> Date: Tue, 23 Jun 2026 03:57:42 +0800 Subject: [PATCH] fix(workbench-runtime): avoid full message scan for sessions (#1946) --- internal/workbenchruntime/service.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/internal/workbenchruntime/service.go b/internal/workbenchruntime/service.go index 06c2542e..892a8ca8 100644 --- a/internal/workbenchruntime/service.go +++ b/internal/workbenchruntime/service.go @@ -1247,8 +1247,8 @@ func (s *Server) querySummaryFacts(ctx context.Context, sessions []map[string]an if len(sessionIDs) > 0 { resultCount++ go func() { - messageFacts, err := s.queryFacts(ctx, factQuery{SessionIDs: sessionIDs, Families: []string{"messages"}, MessagesOrder: "updated_asc"}) - results <- summaryFactsResult{kind: "messageFacts", facts: messageFacts, err: err} + messageSummaries, err := s.queryMessageSummaries(ctx, sessionIDs) + results <- summaryFactsResult{kind: "messageSummaries", facts: map[string][]any{"messageSummaries": messageSummaries}, err: err} }() } if len(traceIDs) > 0 { @@ -1264,7 +1264,7 @@ func (s *Server) querySummaryFacts(ctx context.Context, sessions []map[string]an return nil, result.err } switch result.kind { - case "messageFacts": + case "messageSummaries": facts = mergeFacts(facts, result.facts) case "traceFacts": facts = mergeFacts(facts, result.facts)