We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a9928be commit 2d84b7cCopy full SHA for 2d84b7c
apps/coordinator/src/checkpointer.ts
@@ -436,7 +436,10 @@ export class Checkpointer {
436
this.#logger.error("Error during cleanup", { ...metadata, error });
437
}
438
439
- this.#abortControllers.delete(runId);
+ // Ensure only the current controller is removed
440
+ if (this.#abortControllers.get(runId) === controller) {
441
+ this.#abortControllers.delete(runId);
442
+ }
443
controller.signal.removeEventListener("abort", onAbort);
444
};
445
0 commit comments