mirrors/pikasTech-HWLAB
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(workbench-runtime): avoid full message scan for sessions (#1946)

Browse Source
This commit is contained in:
Lyon
2026-06-23 03:57:42 +08:00
committed by GitHub
parent 2d3edda3fb
commit cf717a5d49
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/workbenchruntime/service.go
+3 -3
View File
@@ -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)