n8n-io/n8n
1
1
Fork 0
mirror of https://github.com/n8n-io/n8n.git synced 2024-09-11 13:15:28 +03:00
Code Issues Projects Releases Wiki Activity

fix(core): Tighten checks for multi-main setup usage (#7788)

Browse Source 
https://n8nio.slack.com/archives/C05HRPLSGTT/p1700731476321999?thread_ts=1700729359.746899&cid=C05HRPLSGTT
This commit is contained in:
Iván Ovejero 2023-11-23 12:18:39 +01:00 committed by GitHub
parent 6208af07eb
commit fdb2c18ecc
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
6 changed files with 15 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
packages/cli/src/ActiveWorkflowRunner.ts
View File

@ -4,7 +4,6 @@
import { Service } from 'typedi';
import { ActiveWorkflows, NodeExecuteFunctions } from 'n8n-core';
import config from '@/config';
import type {
ExecutionError,
@ -99,9 +98,7 @@ export class ActiveWorkflowRunner implements IWebhookManager {
) {}
async init() {
if (config.getEnv('executions.mode') === 'queue' && config.getEnv('multiMainSetup.enabled')) {
await this.multiMainSetup.init();
}
await this.multiMainSetup.init();
await this.addActiveWorkflows('init');

4
packages/cli/src/License.ts
View File

@ -51,9 +51,7 @@ export class License {
return;
}
if (config.getEnv('executions.mode') === 'queue' && config.getEnv('multiMainSetup.enabled')) {
await this.multiMainSetup.init();
}
await this.multiMainSetup.init();
const isMainInstance = instanceType === 'main';
const server = config.getEnv('license.serverUrl');

2
packages/cli/src/commands/start.ts
View File

@ -117,7 +117,7 @@ export class Start extends BaseCommand {
this.pruningService.stopPruning();
}
if (config.getEnv('executions.mode') === 'queue' && config.getEnv('multiMainSetup.enabled')) {
if (Container.get(MultiMainSetup).isEnabled) {
await this.activeWorkflowRunner.removeAllTriggerAndPollerBasedWorkflows();
await Container.get(MultiMainSetup).shutdown();

3
packages/cli/src/services/orchestration/main/MultiMainSetup.ee.ts
View File

@ -14,6 +14,7 @@ export class MultiMainSetup extends SingleMainSetup {
return (
config.getEnv('executions.mode') === 'queue' &&
config.getEnv('multiMainSetup.enabled') &&
config.getEnv('generic.instanceType') === 'main' &&
this.isLicensed
);
}
@ -37,7 +38,7 @@ export class MultiMainSetup extends SingleMainSetup {
private leaderCheckInterval: NodeJS.Timer | undefined;
async init() {
if (this.isInitialized) return;
if (!this.isEnabled || this.isInitialized) return;
await this.initPublisher();

1
packages/cli/src/services/pruning.service.ts
View File

@ -40,6 +40,7 @@ export class PruningService {
if (
config.getEnv('multiMainSetup.enabled') &&
config.getEnv('generic.instanceType') === 'main' &&
config.getEnv('multiMainSetup.instanceType') === 'follower'
) {
return false;

20
packages/cli/src/workflows/workflows.services.ts
View File

@ -372,19 +372,17 @@ export class WorkflowsService {
}
}
if (config.getEnv('executions.mode') === 'queue' && config.getEnv('multiMainSetup.enabled')) {
const multiMainSetup = Container.get(MultiMainSetup);
const multiMainSetup = Container.get(MultiMainSetup);
await multiMainSetup.init();
await multiMainSetup.init();
if (multiMainSetup.isEnabled) {
await Container.get(MultiMainSetup).broadcastWorkflowActiveStateChanged({
workflowId,
oldState,
newState: updatedWorkflow.active,
versionId: shared.workflow.versionId,
});
}
if (multiMainSetup.isEnabled) {
await Container.get(MultiMainSetup).broadcastWorkflowActiveStateChanged({
workflowId,
oldState,
newState: updatedWorkflow.active,
versionId: shared.workflow.versionId,
});
}
return updatedWorkflow;