agent.nextDueMs = seekActiveSlotForAgent(agent, rawDueMs);

};

const advanceStaleScheduleAfterDeferral = (

agent: HeartbeatAgentState,

now: number,

reason?: string,

decision?: DeferDecision,

) => {

if (!decision?.defer || decision.reason === "not-due" || agent.nextDueMs > now) {

return;

}

// Deferrals that do not have wake-layer retry ownership still need to move

// the due slot forward; otherwise scheduleNext() will keep rearming at 0ms.

advanceAgentSchedule(agent, now, reason);

};

// Centralized cooldown gate. Both targeted and broadcast dispatch branches

// call this before invoking `runOnce`. Manual wakes are never deferred.

// Everything else respects `nextDueMs`, the min-spacing floor, and the flood

}

const deferral = evaluateWakeDeferral(targetAgent, now, reason, intent);

if (deferral.defer) {

advanceStaleScheduleAfterDeferral(targetAgent, now, reason, deferral);

return { status: "skipped", reason: deferral.reason };

}

try {

return res;

}

// Non-retryable outcome (ran, disabled, failed-but-not-busy). Record

// bookkeeping so subsequent wakes within the cooldown window defer.

// bookkeeping and move the due slot so scheduleNext() cannot hot-loop

// on a stale past-due agent.

recordRunBookkeeping(targetAgent, now);

if (res.status !== "skipped" || res.reason !== "disabled") {

advanceAgentSchedule(targetAgent, now, reason);

}

advanceAgentSchedule(targetAgent, now, reason);

return res.status === "ran" ? { status: "ran", durationMs: Date.now() - startedAt } : res;

} catch (err) {

const errMsg = formatErrorMessage(err);

const runOneAgent = async (agent: HeartbeatAgentState): Promise<AgentWakeOutcome> => {

const deferral = evaluateWakeDeferral(agent, now, reason, intent);

if (deferral.defer) {

advanceStaleScheduleAfterDeferral(agent, now, reason, deferral);

return { ran: false };

}

}

// Non-retryable outcome — record bookkeeping for cooldown gates.

recordRunBookkeeping(agent, now);

if (res.status !== "skipped" || res.reason !== "disabled") {

advanceAgentSchedule(agent, now, reason);

}

advanceAgentSchedule(agent, now, reason);

let agentRan = res.status === "ran";

const defaultSessionKey = resolveHeartbeatSession(