From 576337ef31704dd8d8f5ff647ffa412373dc780d Mon Sep 17 00:00:00 2001 From: Vincent Koc Date: Fri, 3 Apr 2026 00:14:15 +0900 Subject: [PATCH] fix(tasks): use no-persist cleanup in executor tests --- src/tasks/task-executor.test.ts | 17 ++++++++++------- 1 file changed, 10 insertions(+), 7 deletions(-) diff --git a/src/tasks/task-executor.test.ts b/src/tasks/task-executor.test.ts index 6f0d90c061b..3a4bf92ff77 100644 --- a/src/tasks/task-executor.test.ts +++ b/src/tasks/task-executor.test.ts @@ -1,5 +1,5 @@ import { afterEach, describe, expect, it, vi } from "vitest"; -import { resetAgentEventsForTest } from "../infra/agent-events.js"; +import { resetAgentEventsForTest, resetAgentRunContextForTest } from "../infra/agent-events.js"; import { resetHeartbeatWakeStateForTests } from "../infra/heartbeat-wake.js"; import { resetSystemEventsForTest } from "../infra/system-events.js"; import { withStateDirEnv } from "../test-helpers/state-dir-env.js"; @@ -64,8 +64,9 @@ async function withTaskExecutorStateDir(run: (stateDir: string) => Promise resetHeartbeatWakeStateForTests(); resetAgentEventsForTest(); resetTaskRegistryDeliveryRuntimeForTests(); - resetTaskRegistryForTests(); - resetTaskFlowRegistryForTests(); + resetAgentRunContextForTest(); + resetTaskRegistryForTests({ persist: false }); + resetTaskFlowRegistryForTests({ persist: false }); try { await run(stateDir); } finally { @@ -73,8 +74,9 @@ async function withTaskExecutorStateDir(run: (stateDir: string) => Promise resetHeartbeatWakeStateForTests(); resetAgentEventsForTest(); resetTaskRegistryDeliveryRuntimeForTests(); - resetTaskRegistryForTests(); - resetTaskFlowRegistryForTests(); + resetAgentRunContextForTest(); + resetTaskRegistryForTests({ persist: false }); + resetTaskFlowRegistryForTests({ persist: false }); } }); } @@ -90,8 +92,9 @@ describe("task-executor", () => { resetHeartbeatWakeStateForTests(); resetAgentEventsForTest(); resetTaskRegistryDeliveryRuntimeForTests(); - resetTaskRegistryForTests(); - resetTaskFlowRegistryForTests(); + resetAgentRunContextForTest(); + resetTaskRegistryForTests({ persist: false }); + resetTaskFlowRegistryForTests({ persist: false }); hoisted.sendMessageMock.mockReset(); hoisted.cancelSessionMock.mockReset(); hoisted.killSubagentRunAdminMock.mockReset();