mudhorn/n8n
1
0
Fork 0
mirror of https://github.com/n8n-io/n8n.git synced 2025-03-05 20:50:17 -08:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix(core): Override executions mode if regular during worker startup (#11250)

Browse source
This commit is contained in:
Iván Ovejero 2024-10-14 16:12:41 +02:00
parent 381766523f
commit 0d40874689
No known key found for this signature in database
2 changed files with 8 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
packages/cli/src/commands/worker.ts
View file

@ -61,6 +61,10 @@ export class Worker extends BaseCommand {
} }
constructor(argv: string[], cmdConfig: Config) { constructor(argv: string[], cmdConfig: Config) {
if (config.getEnv('executions.mode') !== 'queue') {
config.set('executions.mode', 'queue');
}
super(argv, cmdConfig); super(argv, cmdConfig);
if (!process.env.N8N_ENCRYPTION_KEY) { if (!process.env.N8N_ENCRYPTION_KEY) {

4
packages/cli/test/integration/commands/worker.cmd.test.ts
View file

@ -35,6 +35,8 @@ mockInstance(Subscriber);
const command = setupTestCommand(Worker); const command = setupTestCommand(Worker);
test('worker initializes all its components', async () => { test('worker initializes all its components', async () => {
config.set('executions.mode', 'regular'); // should be overridden
const worker = await command.run(); const worker = await command.run();
expect(worker.queueModeId).toBeDefined(); expect(worker.queueModeId).toBeDefined();
expect(worker.queueModeId).toContain('worker'); expect(worker.queueModeId).toContain('worker');
@ -49,4 +51,6 @@ test('worker initializes all its components', async () => {
expect(logStreamingEventRelay.init).toHaveBeenCalledTimes(1); expect(logStreamingEventRelay.init).toHaveBeenCalledTimes(1);
expect(orchestrationWorkerService.init).toHaveBeenCalledTimes(1); expect(orchestrationWorkerService.init).toHaveBeenCalledTimes(1);
expect(messageEventBus.send).toHaveBeenCalledTimes(1); expect(messageEventBus.send).toHaveBeenCalledTimes(1);
expect(config.getEnv('executions.mode')).toBe('queue');
}); });