Use env var also for queue mode worker

n8n-io · Jun 10, 2024 · ed2fae0 · ed2fae0
1 parent ef85fbf
commit ed2fae0
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/packages/cli/src/commands/worker.ts b/packages/cli/src/commands/worker.ts
@@ -317,8 +317,12 @@ export class Worker extends BaseCommand {
 		Worker.jobQueue = Container.get(Queue);
 		await Worker.jobQueue.init();
 		this.logger.debug('Queue singleton ready');
+
+		const envConcurrency = config.getEnv('executions.concurrency.productionLimit');
+		const concurrency = envConcurrency !== -1 ? envConcurrency : flags.concurrency;
+
 		void Worker.jobQueue.process(
-			flags.concurrency,
+			concurrency,
 			async (job) => await this.runJob(job, this.nodeTypes),
 		);
 

diff --git a/packages/cli/src/config/schema.ts b/packages/cli/src/config/schema.ts
@@ -256,7 +256,7 @@ export const schema = {
 
 		concurrency: {
 			productionLimit: {
-				doc: 'Max production executions allowed to run concurrently in main mode. -1 to disable.',
+				doc: "Max production executions allowed to run concurrently, in main process for regular mode and in worker for queue mode. Default for main mode is `-1` (disabled). Default for queue mode is taken from the worker's `--concurrency` flag.",
 				format: Number,
 				default: -1,
 				env: 'N8N_CONCURRENCY_PRODUCTION_LIMIT',