mudhorn/n8n
1
0
Fork 0
mirror of https://github.com/n8n-io/n8n.git synced 2025-02-02 07:01:30 -08:00
Code Issues Actions Packages Projects Releases Wiki Activity

feat(core): Rename two task runner env vars (#12763)

Browse source
This commit is contained in:
Tomi Turtiainen 2025-01-22 15:39:02 +02:00 committed by GitHub
parent ba8aa39216
commit 60187cab9b
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
2 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
packages/@n8n/config/src/configs/runners.config.ts
View file

@ -22,12 +22,12 @@ export class TaskRunnersConfig {
@Env('N8N_RUNNERS_AUTH_TOKEN') @Env('N8N_RUNNERS_AUTH_TOKEN')
authToken: string = ''; authToken: string = '';
/** IP address task runners server should listen on */ /** IP address task runners broker should listen on */
@Env('N8N_RUNNERS_HEALTH_CHECK_SERVER_PORT') @Env('N8N_RUNNERS_BROKER_PORT')
port: number = 5679; port: number = 5679;
/** IP address task runners server should listen on */ /** IP address task runners broker should listen on */
@Env('N8N_RUNNERS_SERVER_LISTEN_ADDRESS') @Env('N8N_RUNNERS_BROKER_LISTEN_ADDRESS')
listenAddress: string = '127.0.0.1'; listenAddress: string = '127.0.0.1';
/** Maximum size of a payload sent to the runner in bytes, Default 1G */ /** Maximum size of a payload sent to the runner in bytes, Default 1G */

4
packages/cli/src/task-runners/task-runner-server.ts
View file

@ -100,7 +100,7 @@ export class TaskRunnerServer {
this.server.on('error', (error: Error & { code: string }) => { this.server.on('error', (error: Error & { code: string }) => {
if (error.code === 'EADDRINUSE') { if (error.code === 'EADDRINUSE') {
this.logger.info( 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); process.exit(1);
} }
@ -111,7 +111,7 @@ export class TaskRunnerServer {
this.server.listen(port, address, () => resolve()); 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 */ /** Creates WebSocket server for handling upgrade requests */