refactor(core): Revamp crash recovery mechanism for main mode (#9613)

packages/cli/src/constants.ts

@@ -156,3 +156,14 @@ export const GENERIC_OAUTH2_CREDENTIALS_WITH_EDITABLE_SCOPE = [
 	'microsoftOAuth2Api',
 	'highLevelOAuth2Api',
 ];
+
+export const ARTIFICIAL_TASK_DATA = {
+	main: [
+		[
+			{
+				json: { isArtificialRecoveredEventItem: true },
+				pairedItem: undefined,
+			},
+		],
+	],
+};

packages/cli/src/errors/node-crashed.error.ts

@@ -0,0 +1,12 @@
+import type { INode } from 'n8n-workflow';
+import { NodeOperationError } from 'n8n-workflow';
+
+export class NodeCrashedError extends NodeOperationError {
+	constructor(node: INode) {
+		super(node, 'Node crashed, possible out-of-memory issue', {
+			message: 'Execution stopped at this node',
+			description:
+				"n8n may have run out of memory while running this execution. More context and tips on how to avoid this <a href='https://docs.n8n.io/hosting/scaling/memory-errors/' target='_blank'>in the docs</a>",
+		});
+	}
+}

packages/cli/src/errors/workflow-crashed.error.ts

@@ -0,0 +1,7 @@
+import { WorkflowOperationError } from 'n8n-workflow';
+
+export class WorkflowCrashedError extends WorkflowOperationError {
+	constructor() {
+		super('Workflow did not finish, possible out-of-memory issue');
+	}
+}

packages/cli/src/eventbus/MessageEventBus/MessageEventBus.ts

@@ -32,7 +32,7 @@ import {
 import { METRICS_EVENT_NAME } from '../MessageEventBusDestination/Helpers.ee';
 import type { AbstractEventMessageOptions } from '../EventMessageClasses/AbstractEventMessageOptions';
 import { getEventMessageObjectByType } from '../EventMessageClasses/Helpers';
-import { ExecutionDataRecoveryService } from '../executionDataRecovery.service';
+import { ExecutionRecoveryService } from '../../executions/execution-recovery.service';
 import {
 	EventMessageAiNode,
 	type EventMessageAiNodeOptions,
@@ -68,7 +68,7 @@ export class MessageEventBus extends EventEmitter {
 		private readonly eventDestinationsRepository: EventDestinationsRepository,
 		private readonly workflowRepository: WorkflowRepository,
 		private readonly orchestrationService: OrchestrationService,
-		private readonly recoveryService: ExecutionDataRecoveryService,
+		private readonly recoveryService: ExecutionRecoveryService,
 	) {
 		super();
 	}
@@ -185,10 +185,9 @@ export class MessageEventBus extends EventEmitter {
 							);
 							await this.executionRepository.markAsCrashed([executionId]);
 						} else {
-							await this.recoveryService.recoverExecutionData(
+							await this.recoveryService.recover(
 								executionId,
 								unsentAndUnfinished.unfinishedExecutions[executionId],
-								true,
 							);
 						}
 					}