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

fix(workbench): 用 agent session 上下文补齐 durable 投影 sessionId (#2013)

Browse Source 
* fix(workbench): pass projection context to message writer

* fix(workbench): resolve session id from agent session context
This commit is contained in:
Lyon
2026-06-24 05:02:06 +08:00
committed by GitHub
parent db6e889009
commit d0a00abfce
2 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/cloud/code-agent-trace-store.test.ts
+1 -1
View File
@@ -64,7 +64,7 @@ test("durable code agent trace store projects appended events without counting a
}); });
const traceId = "trc_trace-store-durable-projection"; const traceId = "trc_trace-store-durable-projection";
traceStore.append(traceId, { type: "request", status: "accepted", label: "request:accepted", sessionId: "ses_trace_store_durable" }); traceStore.append(traceId, { type: "request", status: "accepted", label: "request:accepted" }, { agentSessionId: "ses_trace_store_durable" });
traceStore.appendAssistantDelta(traceId, { itemId: "assistant", chunk: "hello" }); traceStore.appendAssistantDelta(traceId, { itemId: "assistant", chunk: "hello" });
await Promise.resolve(); await Promise.resolve();
await Promise.resolve(); await Promise.resolve();
internal/cloud/code-agent-trace-store.ts
+4 -2
View File
@@ -253,10 +253,12 @@ function persistTraceEvent(traceEventStore, event, meta = {}, workbenchEventWrit
async function persistTraceEventAsync(traceEventStore, event, meta = {}, workbenchEventWriter = null) { async function persistTraceEventAsync(traceEventStore, event, meta = {}, workbenchEventWriter = null) {
try { try {
const resolvedAgentSessionId = event.agentSessionId ?? event.sessionId ?? meta.agentSessionId ?? meta.sessionId;
const resolvedSessionId = event.sessionId ?? meta.sessionId ?? resolvedAgentSessionId;
const projectionContext = { const projectionContext = {
traceId: event.traceId, traceId: event.traceId,
agentSessionId: event.agentSessionId ?? event.sessionId ?? meta.agentSessionId ?? meta.sessionId, agentSessionId: resolvedAgentSessionId,
sessionId: event.sessionId ?? meta.sessionId sessionId: resolvedSessionId
}; };
try { try {
await traceEventStore.writeAgentTraceEvent({ event }, projectionContext); await traceEventStore.writeAgentTraceEvent({ event }, projectionContext);