root/fusion
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(FN-4255): complete Step 1 — use interval-based staleness threshold

Browse Source 
Fusion-Task-Id: FN-4255
Fusion-Task-Lineage: 315c5491-0e27-46cb-8474-fda9bb3a0eff
This commit is contained in:
Fusion
2026-05-12 23:36:08 -07:00
committed by gsxdsm
parent b5905dc20d
commit fa8adb5713
1 changed files with 18 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
packages/engine/src/agent-heartbeat.ts
View File

@@ -159,6 +159,17 @@ interface TrackedAgent {
sessionIdBefore?: string;
}
/**
* Grace multiplier applied to each direct report's configured heartbeat
* interval before flagging it stale in reports-health summaries.
*/
const HEARTBEAT_GRACE_MULTIPLIER = 4;
/**
* Minimum staleness threshold floor for very short heartbeat intervals.
*/
const MIN_HEARTBEAT_STALENESS_MS = 5 * 60_000;
/** Format milliseconds into a human-readable duration string (e.g. "5m", "1h 20m", "2h"). */
export function formatDuration(ms: number): string {
const totalMinutes = Math.floor(ms / 60_000);
@@ -2597,7 +2608,11 @@ export class HeartbeatMonitor {
const now = Date.now();
const rows = reports.map((report) => {
const timeoutMs = this.resolveAgentConfig(report.id).heartbeatTimeoutMs;
const { pollIntervalMs, heartbeatTimeoutMs } = this.resolveAgentConfig(report.id);
const staleThresholdMs = Math.max(
pollIntervalMs * HEARTBEAT_GRACE_MULTIPLIER,
MIN_HEARTBEAT_STALENESS_MS,
);
const lastHeartbeatTs = report.lastHeartbeatAt ? Date.parse(report.lastHeartbeatAt) : NaN;
const heartbeatAgeMs = Number.isFinite(lastHeartbeatTs) ? Math.max(0, now - lastHeartbeatTs) : Infinity;
@@ -2607,8 +2622,8 @@ export class HeartbeatMonitor {
} else if (report.state === "error") {
health = "**stuck**";
} else if (report.state === "running") {
health = heartbeatAgeMs <= timeoutMs * 2 ? "healthy" : "**stuck**";
} else if ((report.state === "active" || report.state === "idle") && heartbeatAgeMs > timeoutMs * 3) {
health = heartbeatAgeMs <= heartbeatTimeoutMs * 2 ? "healthy" : "**stuck**";
} else if ((report.state === "active" || report.state === "idle") && heartbeatAgeMs > staleThresholdMs) {
health = "**stale**";
}