fix(core): Prevent workers from recovering executions on startup

packages/cli/src/eventbus/message-event-bus/message-event-bus.ts

@@ -144,7 +144,7 @@ export class MessageEventBus extends EventEmitter {
 
 			// if we are in queue mode, running jobs may still be running on a worker despite the main process
 			// crashing, so we can't just mark them as crashed
-			if (config.get('executions.mode') !== 'queue') {
+			if (config.get('executions.mode') === 'regular') {
 				const dbUnfinishedExecutionIds = (
 					await this.executionRepository.find({
 						where: {

packages/cli/src/executions/__tests__/execution-recovery.service.test.ts

@@ -54,6 +54,31 @@ describe('ExecutionRecoveryService', () => {
 	});
 
 	describe('recoverFromLogs', () => {
+		describe('if not main', () => {
+			test('should do nothing', async () => {
+				const executionRecoveryService = new ExecutionRecoveryService(
+					mock(),
+					mock<InstanceSettings>({ instanceType: 'worker' }),
+					push,
+					executionRepository,
+					mock(),
+				);
+				// @ts-expect-error Private method
+				const amendSpy = jest.spyOn(executionRecoveryService, 'amend');
+				const messages = setupMessages('123', 'Some workflow');
+
+				/**
+				 * Act
+				 */
+				await executionRecoveryService.recoverFromLogs('123', messages);
+
+				/**
+				 * Assert
+				 */
+				expect(amendSpy).not.toHaveBeenCalled();
+			});
+		});
+
 		describe('if follower', () => {
 			test('should do nothing', async () => {
 				/**

packages/cli/src/executions/execution-recovery.service.ts

@@ -12,7 +12,7 @@ import { EventService } from '@/events/event.service';
 import type { IExecutionResponse } from '@/interfaces';
 import { Logger } from '@/logging/logger.service';
 import { Push } from '@/push';
-import { getWorkflowHooksMain } from '@/workflow-execute-additional-data'; // @TODO: Dependency cycle
+import { getWorkflowHooksMain } from '@/workflow-execute-additional-data';
 
 import type { EventMessageTypes } from '../eventbus/event-message-classes';
 
@@ -33,7 +33,7 @@ export class ExecutionRecoveryService {
 	 * Recover key properties of a truncated execution using event logs.
 	 */
 	async recoverFromLogs(executionId: string, messages: EventMessageTypes[]) {
-		if (this.instanceSettings.isFollower) return;
+		if (this.instanceSettings.instanceType !== 'main' || this.instanceSettings.isFollower) return;
 
 		const amendedExecution = await this.amend(executionId, messages);