wip: optimize method has

n8n-io · Jan 14, 2025 · a5ee240 · a5ee240
1 parent ffd5f00
commit a5ee240
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 1 deletion.
diff --git a/packages/cli/src/concurrency/concurrency-control.service.ts b/packages/cli/src/concurrency/concurrency-control.service.ts
@@ -99,7 +99,13 @@ export class ConcurrencyControlService {
 	has(executionId: string) {
 		if (!this.isEnabled) return false;
 
-		return Array.from(this.queues.values()).some((queue) => queue.getAll().has(executionId));
+		for (const queue of this.queues.values()) {
+			if (queue.has(executionId)) {
+				return true;
+			}
+		}
+
+		return false;
 	}
 
 	/**

diff --git a/packages/cli/src/concurrency/concurrency-queue.ts b/packages/cli/src/concurrency/concurrency-queue.ts
@@ -58,6 +58,10 @@ export class ConcurrencyQueue extends TypedEmitter<ConcurrencyEvents> {
 		return new Set(this.queue.map((item) => item.executionId));
 	}
 
+	has(executionId: string) {
+		return this.queue.some((item) => item.executionId === executionId);
+	}
+
 	private resolveNext() {
 		const item = this.queue.shift();