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

feat(FN-4296): complete Step 2 — recover drifted durable agent task links

Browse Source 
Fusion-Task-Id: FN-4296
Fusion-Task-Lineage: 9d061861-547a-4905-8fdd-4b66dd7bff97
This commit is contained in:
Fusion
2026-05-14 05:08:39 -07:00
committed by gsxdsm
parent d3fa2e1a8d
commit f5eaf97697
1 changed files with 56 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

56
packages/engine/src/self-healing.ts
View File

@@ -384,6 +384,7 @@ export class SelfHealingManager {
{ name: "recover-orphaned-agents", fn: () => this.recoverOrphanedAgents().then(() => undefined) },
{ name: "recover-stale-heartbeat-runs", fn: () => this.recoverStaleHeartbeatRuns().then(() => undefined) },
{ name: "recover-running-on-inactive-tasks", fn: () => this.recoverAgentsRunningOnInactiveTasks().then(() => undefined) },
{ name: "recover-drifted-agent-task-links", fn: () => this.recoverDriftedAgentTaskLinks().then(() => undefined) },
{ name: "clear-stale-blocked-by", fn: () => this.clearStaleBlockedBy().then(() => undefined) },
{ name: "reclaim-self-owned-branch-conflicts", fn: () => this.reclaimSelfOwnedBranchConflicts().then(() => undefined) },
{ name: "surface-in-review-stalls", fn: () => this.surfaceInReviewStalls().then(() => undefined) },
@@ -1085,6 +1086,7 @@ export class SelfHealingManager {
{ name: "recover-orphaned-agents", fn: () => this.recoverOrphanedAgents() },
{ name: "recover-stale-heartbeat-runs", fn: () => this.recoverStaleHeartbeatRuns() },
{ name: "recover-running-on-inactive-tasks", fn: () => this.recoverAgentsRunningOnInactiveTasks() },
{ name: "recover-drifted-agent-task-links", fn: () => this.recoverDriftedAgentTaskLinks() },
{ name: "clear-stale-blocked-by", fn: () => this.clearStaleBlockedBy() },
{ name: "reclaim-self-owned-branch-conflicts", fn: () => this.reclaimSelfOwnedBranchConflicts() },
{ name: "surface-in-review-stalls", fn: () => this.surfaceInReviewStalls() },
@@ -2938,6 +2940,60 @@ export class SelfHealingManager {
return recoveredAgentIds.size;
}
async recoverDriftedAgentTaskLinks(): Promise<number> {
const agentStore = this.options.agentStore;
if (!agentStore) {
return 0;
}
const now = Date.now();
const clearedAgentIds = new Set<string>();
const durableAgents = await agentStore.listAgents({ includeEphemeral: false });
for (const agent of durableAgents) {
if (!agent.taskId) {
continue;
}
const linkedTaskId = agent.taskId;
const linkedTask = await this.store.getTask(linkedTaskId);
let shouldClear = false;
let reason = "";
if (!linkedTask) {
shouldClear = true;
reason = "linked task missing";
} else if (linkedTask.column === "done" || linkedTask.column === "archived") {
shouldClear = true;
reason = `linked task in terminal column ${linkedTask.column}`;
} else if (linkedTask.assignedAgentId && linkedTask.assignedAgentId !== agent.id) {
shouldClear = true;
reason = `linked task assigned to ${linkedTask.assignedAgentId}`;
} else if (linkedTask.column === "todo" || linkedTask.column === "triage") {
const activeRun = await agentStore.getActiveHeartbeatRun(agent.id);
const runStartedAt = activeRun?.startedAt;
const runAgeMs = runStartedAt ? now - Date.parse(runStartedAt) : Number.POSITIVE_INFINITY;
const hasFreshRun = Boolean(activeRun) && Number.isFinite(runAgeMs) && runAgeMs <= RUNNING_ON_INACTIVE_TASK_STALE_RUN_MS;
const hasActiveExecution = this.options.hasActiveAgentExecution?.(agent.id) === true;
if (!hasFreshRun && !hasActiveExecution) {
shouldClear = true;
reason = `linked task in queued column ${linkedTask.column} without fresh run`;
}
}
if (!shouldClear) {
continue;
}
await agentStore.syncExecutionTaskLink(agent.id, undefined);
clearedAgentIds.add(agent.id);
log.log(`Cleared drifted durable agent task link for ${agent.id} (${linkedTaskId}): ${reason}`);
}
log.log(`Recovered ${clearedAgentIds.size} drifted durable agent task link(s)`);
return clearedAgentIds.size;
}
async recoverOrphanedAgents(): Promise<number> {
const agentStore = this.options.agentStore;
if (!agentStore) {