mirror of
https://github.com/n8n-io/n8n.git
synced 2025-02-20 18:49:27 -08:00
Story: https://linear.app/n8n/issue/PAY-926 This PR coordinates workflow activation on instance startup and on leadership change in multiple main scenario in the internal API. Part 3 on manual workflow activation and deactivation will be a separate PR. ### Part 1: Instance startup In multi-main scenario, on starting an instance... - [x] If the instance is the leader, it should add webhooks, triggers and pollers. - [x] If the instance is the follower, it should not add webhooks, triggers or pollers. - [x] Unit tests. ### Part 2: Leadership change In multi-main scenario, if the main instance leader dies… - [x] The new main instance leader must activate all trigger- and poller-based workflows, excluding webhook-based workflows. - [x] The old main instance leader must deactivate all trigger- and poller-based workflows, excluding webhook-based workflows. - [x] Unit tests. To test, start two instances and check behavior on startup and leadership change: ``` EXECUTIONS_MODE=queue N8N_LEADER_SELECTION_ENABLED=true N8N_LICENSE_TENANT_ID=... N8N_LICENSE_ACTIVATION_KEY=... N8N_LOG_LEVEL=debug npm run start EXECUTIONS_MODE=queue N8N_LEADER_SELECTION_ENABLED=true N8N_LICENSE_TENANT_ID=... N8N_LICENSE_ACTIVATION_KEY=... N8N_LOG_LEVEL=debug N8N_PORT=5679 npm run start ```
48 lines
1.2 KiB
TypeScript
48 lines
1.2 KiB
TypeScript
import type { INode } from './Interfaces';
|
|
import { ExecutionBaseError, type Severity } from './NodeErrors';
|
|
|
|
interface WorkflowActivationErrorOptions {
|
|
cause?: Error;
|
|
node?: INode;
|
|
severity?: Severity;
|
|
workflowId?: string;
|
|
}
|
|
|
|
/**
|
|
* Class for instantiating an workflow activation error
|
|
*/
|
|
export class WorkflowActivationError extends ExecutionBaseError {
|
|
node: INode | undefined;
|
|
|
|
workflowId: string | undefined;
|
|
|
|
constructor(
|
|
message: string,
|
|
{ cause, node, severity, workflowId }: WorkflowActivationErrorOptions = {},
|
|
) {
|
|
let error = cause as Error;
|
|
if (cause instanceof ExecutionBaseError) {
|
|
error = new Error(cause.message);
|
|
error.constructor = cause.constructor;
|
|
error.name = cause.name;
|
|
error.stack = cause.stack;
|
|
}
|
|
super(message, { cause: error });
|
|
this.node = node;
|
|
this.workflowId = workflowId;
|
|
this.message = message;
|
|
if (severity) this.severity = severity;
|
|
}
|
|
}
|
|
|
|
export class WorkflowDeactivationError extends WorkflowActivationError {}
|
|
|
|
export class WebhookPathAlreadyTakenError extends WorkflowActivationError {
|
|
constructor(nodeName: string, cause?: Error) {
|
|
super(
|
|
`The URL path that the "${nodeName}" node uses is already taken. Please change it to something else.`,
|
|
{ severity: 'warning', cause },
|
|
);
|
|
}
|
|
}
|