From 60187cab9bc9d21aa6ba710d772c068324e429f1 Mon Sep 17 00:00:00 2001
From: Tomi Turtiainen <10324676+tomi@users.noreply.github.com>
Date: Wed, 22 Jan 2025 15:39:02 +0200
Subject: [PATCH] feat(core): Rename two task runner env vars (#12763)

---
 packages/@n8n/config/src/configs/runners.config.ts  | 8 ++++----
 packages/cli/src/task-runners/task-runner-server.ts | 4 ++--
 2 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/packages/@n8n/config/src/configs/runners.config.ts b/packages/@n8n/config/src/configs/runners.config.ts
index 7e192b1be6..af7e911877 100644
--- a/packages/@n8n/config/src/configs/runners.config.ts
+++ b/packages/@n8n/config/src/configs/runners.config.ts
@@ -22,12 +22,12 @@ export class TaskRunnersConfig {
 	@Env('N8N_RUNNERS_AUTH_TOKEN')
 	authToken: string = '';
 
-	/** IP address task runners server should listen on */
-	@Env('N8N_RUNNERS_HEALTH_CHECK_SERVER_PORT')
+	/** IP address task runners broker should listen on */
+	@Env('N8N_RUNNERS_BROKER_PORT')
 	port: number = 5679;
 
-	/** IP address task runners server should listen on */
-	@Env('N8N_RUNNERS_SERVER_LISTEN_ADDRESS')
+	/** IP address task runners broker should listen on */
+	@Env('N8N_RUNNERS_BROKER_LISTEN_ADDRESS')
 	listenAddress: string = '127.0.0.1';
 
 	/** Maximum size of a payload sent to the runner in bytes, Default 1G */
diff --git a/packages/cli/src/task-runners/task-runner-server.ts b/packages/cli/src/task-runners/task-runner-server.ts
index 80679f8c41..cadfd7aadd 100644
--- a/packages/cli/src/task-runners/task-runner-server.ts
+++ b/packages/cli/src/task-runners/task-runner-server.ts
@@ -100,7 +100,7 @@ export class TaskRunnerServer {
 		this.server.on('error', (error: Error & { code: string }) => {
 			if (error.code === 'EADDRINUSE') {
 				this.logger.info(
-					`n8n Task Runner's port ${port} is already in use. Do you have another instance of n8n running already?`,
+					`n8n Task Broker's port ${port} is already in use. Do you have another instance of n8n running already?`,
 				);
 				process.exit(1);
 			}
@@ -111,7 +111,7 @@ export class TaskRunnerServer {
 			this.server.listen(port, address, () => resolve());
 		});
 
-		this.logger.info(`n8n Task Runner server ready on ${address}, port ${port}`);
+		this.logger.info(`n8n Task Broker ready on ${address}, port ${port}`);
 	}
 
 	/** Creates WebSocket server for handling upgrade requests */