farcasclaudiu/openclaw
1
0
Fork 0
mirror of https://github.com/farcasclaudiu/openclaw.git synced 2026-06-28 21:01:43 +03:00
Code Issues Packages Projects Releases Wiki Activity

test(cron): deflake read ops while job is running

Browse Source
This commit is contained in:
Peter Steinberger
2026-02-14 21:00:24 +01:00
parent ffcf37f8c1
commit 82576aa684
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/cron/service.read-ops-nonblocking.test.ts
+4 -4
View File
@@ -84,15 +84,15 @@ describe("CronService read ops while job is running", () => {
await new Promise<void>((resolve) => setTimeout(resolve, 0)); await new Promise<void>((resolve) => setTimeout(resolve, 0));
} }
})(), })(),
200, 2000,
); );
expect(runIsolatedAgentJob).toHaveBeenCalledTimes(1); expect(runIsolatedAgentJob).toHaveBeenCalledTimes(1);
await expect(timeout(cron.list({ includeDisabled: true }), 100)).resolves.toBeTypeOf( await expect(timeout(cron.list({ includeDisabled: true }), 1000)).resolves.toBeTypeOf(
"object", "object",
); );
await expect(timeout(cron.status(), 100)).resolves.toBeTypeOf("object"); await expect(timeout(cron.status(), 1000)).resolves.toBeTypeOf("object");
const running = await cron.list({ includeDisabled: true }); const running = await cron.list({ includeDisabled: true });
expect(running[0]?.state.runningAtMs).toBeTypeOf("number"); expect(running[0]?.state.runningAtMs).toBeTypeOf("number");
@@ -109,7 +109,7 @@ describe("CronService read ops while job is running", () => {
await new Promise<void>((resolve) => setTimeout(resolve, 0)); await new Promise<void>((resolve) => setTimeout(resolve, 0));
} }
})(), })(),
500, 2000,
); );
} finally { } finally {
cron.stop(); cron.stop();