diff --git a/apps/coordinator/src/checkpointer.ts b/apps/coordinator/src/checkpointer.ts index f1b55fa06..bf82a6702 100644 --- a/apps/coordinator/src/checkpointer.ts +++ b/apps/coordinator/src/checkpointer.ts @@ -436,7 +436,10 @@ export class Checkpointer { this.#logger.error("Error during cleanup", { ...metadata, error }); } - this.#abortControllers.delete(runId); + // Ensure only the current controller is removed + if (this.#abortControllers.get(runId) === controller) { + this.#abortControllers.delete(runId); + } controller.signal.removeEventListener("abort", onAbort); };