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

fix: show workbench session read telemetry

Browse Source
This commit is contained in:
Codex
2026-06-26 21:19:17 +00:00
parent c880aa24b8
commit 7f52a4eec1
2 changed files with 58 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
scripts/src/platform-infra-observability/render.ts
+43
View File
@@ -235,6 +235,8 @@ export function renderTraceTable(input: {
});
const runnerRows = traceRunnerRows(allSpans);
const readRows = traceReadWindowRows(allSpans);
const sessionListRows = traceSessionListRows(allSpans);
const sessionMessageRows = traceSessionMessageRows(allSpans);
const turnRows = traceTurnStatusRows(allSpans);
const projectionRows = traceProjectionRows(allSpans);
const countRows = asArray(input.result.spanNameCounts).slice(0, 8).map((item) => {
@@ -270,6 +272,12 @@ export function renderTraceTable(input: {
"Trace read windows:",
formatTable(["TRACE", "SESSION", "SINCE", "LIMIT", "RETURNED", "RANGE", "TOTAL", "MORE", "FULL", "LAST"], readRows.length > 0 ? readRows : [["-", "-", "-", "-", "-", "-", "-", "-", "-", "-"]]),
"",
"Session list reads:",
formatTable(["SOURCE", "COUNT", "FALLBACK", "RATIO", "EMPTY_PREVIEW", "INCLUDE", "SESSIONS", "TRACES"], sessionListRows.length > 0 ? sessionListRows : [["-", "-", "-", "-", "-", "-", "-", "-"]]),
"",
"Session message reads:",
formatTable(["SESSION", "RETURNED", "TOTAL", "ROLES", "USER_PREFIX", "ADJ_SAME", "USER", "AGENT", "TRACES"], sessionMessageRows.length > 0 ? sessionMessageRows : [["-", "-", "-", "-", "-", "-", "-", "-", "-"]]),
"",
"Turn status reads:",
formatTable(["TRACE", "SESSION", "TURN", "STATUS", "PHASE", "ROUTE", "HTTP"], turnRows.length > 0 ? turnRows : [["-", "-", "-", "-", "-", "-", "-"]]),
"",
@@ -350,6 +358,41 @@ function traceReadWindowRows(spans: Record<string, unknown>[]): string[][] {
return dedupeRows(rows).slice(0, 12);
}
function traceSessionListRows(spans: Record<string, unknown>[]): string[][] {
const rows = spans.filter((span) => textValue(span.name) === "session_list_read").map((span) => {
const attrs = asPlainRecord(span.attributes);
return [
shortenEnd(spanColumnAttr(attrs, ["source"]), 10),
shortenEnd(spanColumnAttr(attrs, ["sessionCount"]), 8),
shortenEnd(spanColumnAttr(attrs, ["fallbackTitleCount"]), 8),
shortenEnd(spanColumnAttr(attrs, ["fallbackTitleRatio"]), 8),
shortenEnd(spanColumnAttr(attrs, ["emptyPreviewCount"]), 8),
shortenMiddle(spanColumnAttr(attrs, ["includeSessionId"]), 18),
shortenMiddle(spanColumnAttr(attrs, ["sessionIds"]), 34),
shortenMiddle(spanColumnAttr(attrs, ["traceIds"]), 34),
];
});
return dedupeRows(rows).slice(0, 12);
}
function traceSessionMessageRows(spans: Record<string, unknown>[]): string[][] {
const rows = spans.filter((span) => textValue(span.name) === "session_messages_read").map((span) => {
const attrs = asPlainRecord(span.attributes);
return [
shortenMiddle(spanColumnAttr(attrs, ["sessionId"]), 18),
shortenEnd(spanColumnAttr(attrs, ["returnedMessages"]), 8),
shortenEnd(spanColumnAttr(attrs, ["totalMessages"]), 8),
shortenEnd(spanColumnAttr(attrs, ["roleSequencePrefix"]), 32),
shortenEnd(spanColumnAttr(attrs, ["consecutiveUserPrefix"]), 8),
shortenEnd(spanColumnAttr(attrs, ["adjacentSameRoleCount"]), 8),
shortenEnd(spanColumnAttr(attrs, ["userCount"]), 8),
shortenEnd(spanColumnAttr(attrs, ["agentCount"]), 8),
shortenMiddle(spanColumnAttr(attrs, ["traceIds"]), 34),
];
});
return dedupeRows(rows).slice(0, 12);
}
function traceTurnStatusRows(spans: Record<string, unknown>[]): string[][] {
const rows = spans.filter((span) => textValue(span.name) === "turn_status_read").map((span) => {
const attrs = asPlainRecord(span.attributes);