return { currentTasks };

}

function expectMaintenanceCounts(

result: Awaited<ReturnType<typeof runTaskRegistryMaintenance>>,

expected: { reconciled: number; recovered?: number },

): void {

expect(result.reconciled).toBe(expected.reconciled);

if (expected.recovered !== undefined) {

expect(result.recovered).toBe(expected.recovered);

}

}

function expectTaskStatus(

tasks: Map<string, TaskRecord>,

taskId: string,

status: TaskRecord["status"],

): void {

const task = tasks.get(taskId);

if (!task) {

throw new Error(`Expected task ${taskId}`);

}

expect(task.status).toBe(status);

}

describe("task-registry maintenance issue #60299", () => {

it("reuses session store reads across stale subagent task checks in one pass", async () => {

const tasks = Array.from({ length: 10 }, (_, index) =>

resolveStorePath: () => "/tmp/openclaw-test-sessions-main.json",

});

expect(await runTaskRegistryMaintenance()).toMatchObject({ reconciled: tasks.length });

expectMaintenanceCounts(await runTaskRegistryMaintenance(), { reconciled: tasks.length });

expect(loadSessionStoreMock).toHaveBeenCalledTimes(1);

});

deriveSessionChatTypeFromKey: deriveSessionChatTypeMock,

});

expect(await runTaskRegistryMaintenance()).toMatchObject({ reconciled: tasks.length });

expectMaintenanceCounts(await runTaskRegistryMaintenance(), { reconciled: tasks.length });

expect(deriveSessionChatTypeMock).toHaveBeenCalledTimes(1);

});

sessionStore: { [childSessionKey]: { sessionId: childSessionKey, updatedAt: Date.now() } },

});

expect(await runTaskRegistryMaintenance()).toMatchObject({ reconciled: 1 });

expect(currentTasks.get(task.taskId)).toMatchObject({ status: "lost" });

expectMaintenanceCounts(await runTaskRegistryMaintenance(), { reconciled: 1 });

expectTaskStatus(currentTasks, task.taskId, "lost");

});

it("keeps active cron tasks live while the cron runtime still owns the job", async () => {

activeCronJobIds: ["cron-job-2"],

});

expect(await runTaskRegistryMaintenance()).toMatchObject({ reconciled: 0 });

expect(currentTasks.get(task.taskId)).toMatchObject({ status: "running" });

expectMaintenanceCounts(await runTaskRegistryMaintenance(), { reconciled: 0 });

expectTaskStatus(currentTasks, task.taskId, "running");

});

it("only treats started non-ended running tasks as restart blockers", () => {