Skip to content

Commit 95b6df8

Browse files
committed
refactor(agents): remove stale lane auto-resume helper
1 parent 8f48f5e commit 95b6df8

2 files changed

Lines changed: 4 additions & 12 deletions

File tree

src/agents/session-suspension.test.ts

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -40,10 +40,10 @@ async function suspendLane(ttlMs: number, cfg: OpenClawConfig, laneId: CommandLa
4040

4141
describe("session suspension", () => {
4242
afterEach(async () => {
43-
const { cancelLaneAutoResume } = await import("./session-suspension.js");
44-
cancelLaneAutoResume(CommandLane.Main);
45-
cancelLaneAutoResume(CommandLane.Cron);
46-
cancelLaneAutoResume(CommandLane.CronNested);
43+
if (vi.isFakeTimers()) {
44+
await vi.runOnlyPendingTimersAsync();
45+
vi.clearAllTimers();
46+
}
4747
vi.useRealTimers();
4848
sessionStoreMocks.applySessionStoreEntryPatch.mockClear();
4949
commandQueueMocks.setCommandLaneConcurrency.mockClear();

src/agents/session-suspension.ts

Lines changed: 0 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -107,14 +107,6 @@ function scheduleLaneAutoResume(laneId: string, delayMs: number, resumeConcurren
107107
laneResumeTimers.set(laneId, timer);
108108
}
109109

110-
export function cancelLaneAutoResume(laneId: string) {
111-
const existing = laneResumeTimers.get(laneId);
112-
if (existing) {
113-
clearTimeout(existing);
114-
laneResumeTimers.delete(laneId);
115-
}
116-
}
117-
118110
export async function suspendSession(params: SessionSuspensionParams) {
119111
if (!params.cfg) {
120112
return;

0 commit comments

Comments
 (0)