mirror of
https://github.com/Abdulazizzn/n8n-enterprise-unlocked.git
synced 2025-12-22 04:10:01 +00:00
fix(core): Register transition handlers after modules init (#16308)
This commit is contained in:
@@ -31,7 +31,6 @@ import { ModuleRegistry } from '@/modules/module-registry';
|
|||||||
import { ModulesConfig } from '@/modules/modules.config';
|
import { ModulesConfig } from '@/modules/modules.config';
|
||||||
import { NodeTypes } from '@/node-types';
|
import { NodeTypes } from '@/node-types';
|
||||||
import { PostHogClient } from '@/posthog';
|
import { PostHogClient } from '@/posthog';
|
||||||
import { MultiMainSetup } from '@/scaling/multi-main-setup.ee';
|
|
||||||
import { ShutdownService } from '@/shutdown/shutdown.service';
|
import { ShutdownService } from '@/shutdown/shutdown.service';
|
||||||
import { WorkflowHistoryManager } from '@/workflows/workflow-history.ee/workflow-history-manager.ee';
|
import { WorkflowHistoryManager } from '@/workflows/workflow-history.ee/workflow-history-manager.ee';
|
||||||
|
|
||||||
@@ -86,10 +85,6 @@ export abstract class BaseCommand extends Command {
|
|||||||
}
|
}
|
||||||
|
|
||||||
this.moduleRegistry.addEntities();
|
this.moduleRegistry.addEntities();
|
||||||
|
|
||||||
if (this.instanceSettings.isMultiMain) {
|
|
||||||
Container.get(MultiMainSetup).registerEventHandlers();
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
async init(): Promise<void> {
|
async init(): Promise<void> {
|
||||||
|
|||||||
@@ -249,6 +249,10 @@ export class Start extends BaseCommand {
|
|||||||
}
|
}
|
||||||
|
|
||||||
await this.moduleRegistry.initModules();
|
await this.moduleRegistry.initModules();
|
||||||
|
|
||||||
|
if (this.instanceSettings.isMultiMain) {
|
||||||
|
Container.get(MultiMainSetup).registerEventHandlers();
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
async initOrchestration() {
|
async initOrchestration() {
|
||||||
|
|||||||
@@ -27,7 +27,6 @@ export class InsightsService {
|
|||||||
this.logger = this.logger.scoped('insights');
|
this.logger = this.logger.scoped('insights');
|
||||||
}
|
}
|
||||||
|
|
||||||
@OnLeaderTakeover()
|
|
||||||
startTimers() {
|
startTimers() {
|
||||||
this.collectionService.startFlushingTimer();
|
this.collectionService.startFlushingTimer();
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user