test: follow deferred cron startup catch-up · openclaw/openclaw@2a64f1a

Recent Commits to openclaw:main

steipete · 2026-04-29 · via Recent Commits to openclaw:main

Original file line number	Diff line number	Diff line change
`@@ -214,7 +214,7 @@ describe("CronService read ops while job is running", () => {`
`214`	`214`	`}`
`215`	`215`	`});`
`216`	`216`
`217`		`-it("keeps list and status responsive during startup catch-up runs", async () => {`
	`217`	`+it("keeps list and status responsive after startup defers catch-up runs", async () => {`
`218`	`218`	`const store = await makeStorePath();`
`219`	`219`	`const enqueueSystemEvent = vi.fn();`
`220`	`220`	`const requestHeartbeatNow = vi.fn();`
`@@ -249,12 +249,12 @@ describe("CronService read ops while job is running", () => {`
`249`	`249`	`enqueueSystemEvent,`
`250`	`250`	`requestHeartbeatNow,`
`251`	`251`	`runIsolatedAgentJob: isolatedRun.runIsolatedAgentJob,`
	`252`	`+startupDeferredMissedAgentJobDelayMs: 120_000,`
`252`	`253`	`});`
`253`	`254`
`254`	`255`	`try {`
`255`		`-const startPromise = cron.start();`
`256`		`-await isolatedRun.runStarted;`
`257`		`-expect(isolatedRun.runIsolatedAgentJob).toHaveBeenCalledTimes(1);`
	`256`	`+await cron.start();`
	`257`	`+expect(isolatedRun.runIsolatedAgentJob).not.toHaveBeenCalled();`
`258`	`258`
`259`	`259`	`await expect(`
`260`	`260`	`withTimeout(cron.list({ includeDisabled: true }), 300, "cron.list during startup"),`
`@@ -263,12 +263,10 @@ describe("CronService read ops while job is running", () => {`
`263`	`263`	`expect.objectContaining({ enabled: true, storePath: store.storePath }),`
`264`	`264`	`);`
`265`	`265`
`266`		`-isolatedRun.completeRun({ status: "ok", summary: "done" });`
`267`		`-await startPromise;`
`268`		`-`
`269`	`266`	`const jobs = await cron.list({ includeDisabled: true });`
`270`		`-expect(jobs[0]?.state.lastStatus).toBe("ok");`
	`267`	`+expect(jobs[0]?.state.lastStatus).toBeUndefined();`
`271`	`268`	`expect(jobs[0]?.state.runningAtMs).toBeUndefined();`
	`269`	`+expect(jobs[0]?.state.nextRunAtMs).toBe(nowMs + 120_000);`
`272`	`270`	`} finally {`
`273`	`271`	`cron.stop();`
`274`	`272`	`await store.cleanup();`

Original file line number	Diff line number	Diff line change
`@@ -7,6 +7,7 @@ import { loadCronStore } from "../store.js";`
`7`	`7`	`import type { CronJob } from "../types.js";`
`8`	`8`	`import { run, start, stop, update } from "./ops.js";`
`9`	`9`	`import { createCronServiceState } from "./state.js";`
	`10`	`+import { runMissedJobs } from "./timer.js";`
`10`	`11`
`11`	`12`	`const { logger, makeStorePath } = setupCronServiceSuite({`
`12`	`13`	`prefix: "cron-service-ops-seam",`
`@@ -326,25 +327,26 @@ describe("cron service ops seam coverage", () => {`
`326`	`327`	`const now = Date.parse("2026-03-23T12:00:00.000Z");`
`327`	`328`	`const restoreStateDir = withStateDirForStorePath(storePath);`
`328`	`329`
`329`		`-await writeCronStoreSnapshot({`
`330`		`- storePath,`
`331`		`-jobs: [createMissedIsolatedJob(now)],`
`332`		`-});`
`333`		`-`
`334`		`-const state = createTimedOutIsolatedCronState({`
`335`		`- storePath,`
`336`		`- now,`
`337`		`-});`
	`330`	`+try {`
	`331`	`+await writeCronStoreSnapshot({`
	`332`	`+ storePath,`
	`333`	`+jobs: [createMissedIsolatedJob(now)],`
	`334`	`+});`
`338`	`335`
`339`		`-await start(state);`
	`336`	`+const state = createTimedOutIsolatedCronState({`
	`337`	`+ storePath,`
	`338`	`+ now,`
	`339`	`+});`
`340`	`340`
`341`		-expect(findTaskByRunId(`cron:startup-timeout:${now}`)).toMatchObject({
`342`		`-runtime: "cron",`
`343`		`-status: "timed_out",`
`344`		`-sourceId: "startup-timeout",`
`345`		`-});`
	`341`	`+await runMissedJobs(state);`
`346`	`342`
`347`		`-restoreStateDir();`
`348`		`-stop(state);`
	`343`	+expect(findTaskByRunId(`cron:startup-timeout:${now}`)).toMatchObject({
	`344`	`+runtime: "cron",`
	`345`	`+status: "timed_out",`
	`346`	`+sourceId: "startup-timeout",`
	`347`	`+});`
	`348`	`+} finally {`
	`349`	`+restoreStateDir();`
	`350`	`+}`
`349`	`351`	`});`
`350`	`352`	`});`

此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。原文来自 — 版权归原作者所有。

推荐订阅源

Recent Commits to openclaw:main