feat: add possibility to configure stop time for workers (#4012)

* feat: add a timer to gracefully control how long workers wait before exiting
This commit is contained in:
Omar Ajoue 2022-09-02 15:40:45 +02:00 committed by GitHub
parent aec5c26564
commit a3791c22b3
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 7 additions and 1 deletions

View file

@ -85,7 +85,7 @@ export class Worker extends Command {
const externalHooks = ExternalHooks(); const externalHooks = ExternalHooks();
await externalHooks.run('n8n.stop', []); await externalHooks.run('n8n.stop', []);
const maxStopTime = 30000; const maxStopTime = config.getEnv('queue.bull.gracefulShutdownTimeout') * 1000;
const stopTime = new Date().getTime() + maxStopTime; const stopTime = new Date().getTime() + maxStopTime;

View file

@ -351,6 +351,12 @@ export const schema = {
default: 60, default: 60,
env: 'QUEUE_RECOVERY_INTERVAL', env: 'QUEUE_RECOVERY_INTERVAL',
}, },
gracefulShutdownTimeout: {
doc: 'How long should n8n wait for running executions before exiting worker process',
format: Number,
default: 30,
env: 'QUEUE_WORKER_TIMEOUT',
},
}, },
}, },