From 7e4183409409210545c03d66372e9edec9d9abc5 Mon Sep 17 00:00:00 2001 From: Christian Byrne Date: Sat, 19 Jul 2025 14:25:54 -0700 Subject: [PATCH] [fix] Handle missing _listenerController.abort when loading workflows (#1134) --- src/subgraph/SubgraphNode.ts | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 deletions(-) diff --git a/src/subgraph/SubgraphNode.ts b/src/subgraph/SubgraphNode.ts index a5295b94e4..e50a3960fd 100644 --- a/src/subgraph/SubgraphNode.ts +++ b/src/subgraph/SubgraphNode.ts @@ -95,7 +95,9 @@ export class SubgraphNode extends LGraphNode implements BaseLGraph { } #addSubgraphInputListeners(subgraphInput: SubgraphInput, input: INodeInputSlot & Partial) { - input._listenerController?.abort() + if (input._listenerController && typeof input._listenerController.abort === "function") { + input._listenerController.abort() + } input._listenerController = new AbortController() const { signal } = input._listenerController @@ -131,7 +133,9 @@ export class SubgraphNode extends LGraphNode implements BaseLGraph { override configure(info: ExportedSubgraphInstance): void { for (const input of this.inputs) { - input._listenerController?.abort() + if (input._listenerController && typeof input._listenerController.abort === "function") { + input._listenerController.abort() + } } this.inputs.length = 0 @@ -309,7 +313,9 @@ export class SubgraphNode extends LGraphNode implements BaseLGraph { override onRemoved(): void { for (const input of this.inputs) { - input._listenerController?.abort() + if (input._listenerController && typeof input._listenerController.abort === "function") { + input._listenerController.abort() + } } } }