diff --git a/packages/cli/src/commands/BaseCommand.ts b/packages/cli/src/commands/BaseCommand.ts index a6a81805d4ebe..5cd5b0cbbfe02 100644 --- a/packages/cli/src/commands/BaseCommand.ts +++ b/packages/cli/src/commands/BaseCommand.ts @@ -44,7 +44,7 @@ export abstract class BaseCommand extends Command { /** * How long to wait for graceful shutdown before force killing the process. */ - protected gracefulShutdownTimeoutInS: number = config.getEnv('generic.gracefulShutdownTimeout'); + protected gracefulShutdownTimeoutInS = config.getEnv('generic.gracefulShutdownTimeout'); async init(): Promise { await initErrorHandling(); diff --git a/packages/cli/src/commands/worker.ts b/packages/cli/src/commands/worker.ts index b8a47b86e5eef..07d8e9d899761 100644 --- a/packages/cli/src/commands/worker.ts +++ b/packages/cli/src/commands/worker.ts @@ -267,9 +267,10 @@ export class Worker extends BaseCommand { } async init() { - const configuredShutdownTimeout = config.getEnv('queue.bull.gracefulShutdownTimeout'); - if (configuredShutdownTimeout) { - this.gracefulShutdownTimeoutInS = configuredShutdownTimeout; + const { QUEUE_WORKER_TIMEOUT } = process.env; + if (QUEUE_WORKER_TIMEOUT) { + this.gracefulShutdownTimeoutInS = + parseInt(QUEUE_WORKER_TIMEOUT, 10) || config.default('queue.bull.gracefulShutdownTimeout'); this.logger.warn( 'QUEUE_WORKER_TIMEOUT has been deprecated. Rename it to N8N_GRACEFUL_SHUTDOWN_TIMEOUT.', );