@@ -8,6 +8,10 @@ import {
88resolveActiveReplyRunSessionId,
99waitForReplyRunEndBySessionId,
1010} from "../../auto-reply/reply/reply-run-registry.js";
11+import {
12+markDiagnosticEmbeddedRunEnded,
13+markDiagnosticEmbeddedRunStarted,
14+} from "../../logging/diagnostic-run-activity.js";
1115import {
1216diagnosticLogger as diag,
1317logMessageQueued,
@@ -366,6 +370,7 @@ export function setActiveEmbeddedRun(
366370state: "processing",
367371reason: wasActive ? "run_replaced" : "run_started",
368372});
373+markDiagnosticEmbeddedRunStarted({ sessionId, sessionKey });
369374if (!sessionId.startsWith("probe-")) {
370375diag.debug(`run registered: sessionId=${sessionId} totalActive=${ACTIVE_EMBEDDED_RUNS.size}`);
371376}
@@ -392,6 +397,7 @@ export function clearActiveEmbeddedRun(
392397EMBEDDED_RUN_MODEL_SWITCH_REQUESTS.delete(sessionId);
393398clearActiveRunSessionKeys(sessionId, sessionKey);
394399logSessionStateChange({ sessionId, sessionKey, state: "idle", reason: "run_completed" });
400+markDiagnosticEmbeddedRunEnded({ sessionId, sessionKey });
395401if (!sessionId.startsWith("probe-")) {
396402diag.debug(`run cleared: sessionId=${sessionId} totalActive=${ACTIVE_EMBEDDED_RUNS.size}`);
397403}
@@ -413,6 +419,7 @@ export function forceClearEmbeddedPiRun(
413419EMBEDDED_RUN_MODEL_SWITCH_REQUESTS.delete(sessionId);
414420clearActiveRunSessionKeys(sessionId, sessionKey);
415421logSessionStateChange({ sessionId, sessionKey, state: "idle", reason });
422+markDiagnosticEmbeddedRunEnded({ sessionId, sessionKey });
416423notifyEmbeddedRunEnded(sessionId);
417424cleared = true;
418425}
此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。 原文来自 — 版权归原作者所有。