wip: fix concurrency queues initialization

n8n-io · Dec 27, 2024 · e467f5e · e467f5e
1 parent 7340fa7
commit e467f5e
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/packages/cli/src/concurrency/__tests__/concurrency-control.service.test.ts b/packages/cli/src/concurrency/__tests__/concurrency-control.service.test.ts
@@ -57,6 +57,8 @@ describe('ConcurrencyControlService', () => {
 				expect(service.isEnabled).toBe(true);
 				// @ts-expect-error Private property
 				expect(service.queues.get(type)).toBeDefined();
+				// @ts-expect-error Private property
+				expect(service.queues.size).toBe(1);
 			},
 		);
 

diff --git a/packages/cli/src/concurrency/concurrency-control.service.ts b/packages/cli/src/concurrency/concurrency-control.service.ts
@@ -63,7 +63,9 @@ export class ConcurrencyControlService {
 
 		this.queues = new Map();
 		this.limits.forEach((limit, type) => {
-			this.queues.set(type, new ConcurrencyQueue(limit));
+			if (limit > 0) {
+				this.queues.set(type, new ConcurrencyQueue(limit));
+			}
 		});
 
 		this.logInit();