vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-04-08 07:41:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

test: drain cron regression queue work before cleanup

Browse Source
This commit is contained in:
Shakker
2026-04-02 01:43:22 +01:00
committed by Peter Steinberger
parent 6299a5fbfe
commit a65ff4de9f
2 changed files with 11 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/cron/service.regression-fixtures.ts
View File

@@ -6,7 +6,7 @@ import { afterAll, afterEach, beforeAll, beforeEach, vi } from "vitest";
import { clearAllBootstrapSnapshots } from "../agents/bootstrap-cache.js";
import { clearSessionStoreCacheForTest } from "../config/sessions/store.js";
import { resetAgentRunContextForTest } from "../infra/agent-events.js";
import { resetCommandQueueStateForTest } from "../process/command-queue.js";
import { resetCommandQueueStateForTest, waitForActiveTasks } from "../process/command-queue.js";
import { useFrozenTime, useRealTime } from "../test-utils/frozen-time.js";
import { createCronServiceState, type CronServiceDeps } from "./service/state.js";
import type { CronJob, CronJobState } from "./types.js";
@@ -34,10 +34,11 @@ export function setupCronRegressionFixtures(options?: { prefix?: string; baseTim
useFrozenTime(options?.baseTimeIso ?? "2026-02-06T10:05:00.000Z");
});
afterEach(() => {
afterEach(async () => {
vi.clearAllTimers();
vi.restoreAllMocks();
useRealTime();
await waitForActiveTasks(250);
resetCommandQueueStateForTest();
clearSessionStoreCacheForTest();
resetAgentRunContextForTest();
@@ -46,6 +47,7 @@ export function setupCronRegressionFixtures(options?: { prefix?: string; baseTim
afterAll(async () => {
useRealTime();
await waitForActiveTasks(250);
await fs.rm(fixtureRoot, { recursive: true, force: true });
});
@@ -127,8 +129,10 @@ export function createDefaultIsolatedRunner(): CronServiceDeps["runIsolatedAgent
export function createAbortAwareIsolatedRunner(summary = "late") {
let observedAbortSignal: AbortSignal | undefined;
const started = createDeferred<void>();
const runIsolatedAgentJob = vi.fn(async ({ abortSignal }) => {
observedAbortSignal = abortSignal;
started.resolve();
await new Promise<void>((resolve) => {
if (!abortSignal) {
return;
@@ -145,6 +149,7 @@ export function createAbortAwareIsolatedRunner(summary = "late") {
return {
runIsolatedAgentJob,
getObservedAbortSignal: () => observedAbortSignal,
waitForStart: () => started.promise,
};
}

6
src/cron/service/ops.regression.test.ts
View File

@@ -194,7 +194,6 @@ describe("cron service ops regressions", () => {
});
it("applies timeoutSeconds to manual cron.run isolated executions", async () => {
vi.useRealTimers();
const store = opsRegressionFixtures.makeStorePath();
const scheduledAt = Date.parse("2026-02-15T13:00:00.000Z");
const job = createIsolatedRegressionJob({
@@ -217,7 +216,10 @@ describe("cron service ops regressions", () => {
runIsolatedAgentJob: abortAwareRunner.runIsolatedAgentJob,
});
const result = await run(state, job.id, "force");
const resultPromise = run(state, job.id, "force");
await abortAwareRunner.waitForStart();
await vi.advanceTimersByTimeAsync(10);
const result = await resultPromise;
expect(result).toEqual({ ok: true, ran: true });
expect(abortAwareRunner.getObservedAbortSignal()?.aborted).toBe(true);