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

fix(workbench): derive session terminal status from durable trace

Browse Source
This commit is contained in:
lyon
2026-06-21 01:56:09 +08:00
parent cd981355c6
commit 49e42be440
1 changed files with 12 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/cloud/server-workbench-http.ts
+12 -4
View File
@@ -501,8 +501,11 @@ function factSessionSummary(session, facts = {}) {
const projection = traceId ? factProjectionForTrace(facts, traceId) : null;
const turn = traceId ? factTurnForTrace(facts, traceId) : null;
const checkpoint = traceId ? factCheckpointForTrace(facts, traceId) : null;
const trace = traceId ? factTraceSnapshot(facts, traceId) : null;
const messages = factMessagesForSession(session, facts);
const status = normalizeStatus(turn?.status ?? session?.status);
const traceStatus = normalizeTerminalStatus(trace?.status);
const checkpointStatus = normalizeTerminalStatus(checkpoint?.status);
const status = normalizeStatus(turn?.status ?? checkpointStatus ?? traceStatus ?? session?.status);
const timingSource = checkpoint ?? (traceId ? null : session);
const timing = factTimingProjection(timingSource, status);
return {
@@ -528,7 +531,7 @@ function factSessionSummary(session, facts = {}) {
status: normalizeStatus(turn.status ?? status),
running: RUNNING_STATUSES.has(normalizeStatus(turn.status ?? status)),
terminal: TERMINAL_STATUSES.has(normalizeStatus(turn.status ?? status)) && !RUNNING_STATUSES.has(normalizeStatus(turn.status ?? status)),
eventCount: projection?.lastProjectedSeq ?? factTraceSnapshot(facts, traceId).eventCount,
eventCount: projection?.lastProjectedSeq ?? trace?.eventCount,
projection,
projectionStatus: projection?.projectionStatus ?? null,
projectionHealth: projection?.projectionHealth ?? null,
@@ -644,13 +647,13 @@ function factTurnForTrace(facts = {}, traceId, turnId = null) {
function factTurnSnapshot({ turn = null, session = null, facts = {}, traceId, turnId = null } = {}) {
const safeTrace = safeTraceId(traceId);
const resolvedTurnId = factTurnId(turn, safeTrace) ?? safeTurnId(turnId) ?? safeTrace;
const status = normalizeStatus(turn?.status ?? session?.status);
const messages = session ? factMessagesForSession(session, facts) : [];
const userMessage = messages.find((message) => message.role === "user") ?? null;
const assistantMessage = [...messages].reverse().find((message) => isAssistantLikeRole(message.role)) ?? null;
const checkpoint = safeTrace ? factCheckpointForTrace(facts, safeTrace) : null;
const finalText = projectionText(turn?.finalResponse, turn?.assistantText, turn?.text, assistantMessage?.text);
const trace = factTraceSnapshot(facts, safeTrace);
const status = normalizeStatus(turn?.status ?? normalizeTerminalStatus(checkpoint?.status) ?? normalizeTerminalStatus(trace.status) ?? session?.status);
const finalText = projectionText(turn?.finalResponse, turn?.assistantText, turn?.text, assistantMessage?.text);
const timing = factTimingProjection(checkpoint, status);
return {
turnId: resolvedTurnId,
@@ -1855,6 +1858,11 @@ function normalizeStatus(value) {
return text || "unknown";
}
function normalizeTerminalStatus(value) {
const status = normalizeStatus(value);
return TERMINAL_STATUSES.has(status) && !RUNNING_STATUSES.has(status) ? status : null;
}
function firstUserPreview(messages) {
return messages.find((message) => message.role === "user")?.textPreview ?? null;
}