github/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-05-09 20:44:32 +00:00
Code Issues Packages Projects Releases Wiki Activity

test (cron): cover interrupted startup job replay guard

Browse Source
This commit is contained in:
Vignesh Natarajan
2026-02-14 19:06:24 -08:00
parent 7b89e68d18
commit bb67585674
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/cron/service.restart-catchup.test.ts
View File

@@ -98,7 +98,7 @@ describe("CronService restart catch-up", () => {
await store.cleanup(); await store.cleanup();
}); });
it("clears stale running markers and catches up overdue jobs on startup", async () => { it("clears stale running markers without replaying interrupted startup jobs", async () => {
const store = await makeStorePath(); const store = await makeStorePath();
const enqueueSystemEvent = vi.fn(); const enqueueSystemEvent = vi.fn();
const requestHeartbeatNow = vi.fn(); const requestHeartbeatNow = vi.fn();
@@ -147,7 +147,7 @@ describe("CronService restart catch-up", () => {
await cron.start(); await cron.start();
expect(enqueueSystemEvent).toHaveBeenCalledWith("resume stale marker", { agentId: undefined }); expect(enqueueSystemEvent).not.toHaveBeenCalled();
expect(noopLogger.warn).toHaveBeenCalledWith( expect(noopLogger.warn).toHaveBeenCalledWith(
expect.objectContaining({ jobId: "restart-stale-running" }), expect.objectContaining({ jobId: "restart-stale-running" }),
"cron: clearing stale running marker on startup", "cron: clearing stale running marker on startup",
@@ -156,8 +156,9 @@ describe("CronService restart catch-up", () => {
const jobs = await cron.list({ includeDisabled: true }); const jobs = await cron.list({ includeDisabled: true });
const updated = jobs.find((job) => job.id === "restart-stale-running"); const updated = jobs.find((job) => job.id === "restart-stale-running");
expect(updated?.state.runningAtMs).toBeUndefined(); expect(updated?.state.runningAtMs).toBeUndefined();
expect(updated?.state.lastStatus).toBe("ok"); expect(updated?.state.lastStatus).toBeUndefined();
expect(updated?.state.lastRunAtMs).toBe(Date.parse("2025-12-13T17:00:00.000Z")); expect(updated?.state.lastRunAtMs).toBeUndefined();
expect((updated?.state.nextRunAtMs ?? 0) > Date.parse("2025-12-13T17:00:00.000Z")).toBe(true);
cron.stop(); cron.stop();
await store.cleanup(); await store.cleanup();