diff --git a/internal-packages/run-engine/src/engine/systems/runAttemptSystem.ts b/internal-packages/run-engine/src/engine/systems/runAttemptSystem.ts index 11a42121e..6dfb71c39 100644 --- a/internal-packages/run-engine/src/engine/systems/runAttemptSystem.ts +++ b/internal-packages/run-engine/src/engine/systems/runAttemptSystem.ts @@ -1102,6 +1102,8 @@ export class RunAttemptSystem { output: { value: JSON.stringify(error), isError: true }, }); + await this.#finalizeRun(run); + this.$.eventBus.emit("runCancelled", { time: new Date(), run: { diff --git a/packages/core/src/v3/workers/taskExecutor.ts b/packages/core/src/v3/workers/taskExecutor.ts index a7e7ba9c7..eafe00b1f 100644 --- a/packages/core/src/v3/workers/taskExecutor.ts +++ b/packages/core/src/v3/workers/taskExecutor.ts @@ -441,7 +441,6 @@ export class TaskExecutor { const abortPromise = new Promise((_, reject) => { signal.addEventListener("abort", () => { if (typeof signal.reason === "string" && signal.reason.includes("cancel")) { - console.log("abortPromise: cancel"); return; }