fix: Show actual execution data for production executions even if pin data exists

packages/editor-ui/src/components/WorkflowPreview.vue

@@ -27,6 +27,7 @@ import { useToast } from '@/composables';
 import type { IWorkflowDb } from '@/Interface';
 import { mapStores } from 'pinia';
 import { useRootStore } from '@/stores/n8nRoot.store';
+import { useWorkflowsStore } from '@/stores';
 
 export default defineComponent({
 	name: 'WorkflowPreview',
@@ -73,7 +74,7 @@ export default defineComponent({
 		};
 	},
 	computed: {
-		...mapStores(useRootStore),
+		...mapStores(useRootStore, useWorkflowsStore),
 		showPreview(): boolean {
 			return (
 				!this.loading &&
@@ -134,6 +135,16 @@ export default defineComponent({
 						}),
 						'*',
 					);
+
+					if (this.workflowsStore.activeWorkflowExecution) {
+						iframeRef.contentWindow.postMessage(
+							JSON.stringify({
+								command: 'setActiveExecution',
+								execution: this.workflowsStore.activeWorkflowExecution,
+							}),
+							'*',
+						);
+					}
 				}
 			} catch (error) {
 				this.showError(

packages/editor-ui/src/mixins/__tests__/workflowHelpers.test.ts

@@ -0,0 +1,37 @@
+import { shouldReplaceInputDataWithPinData } from '../workflowHelpers';
+import { createTestingPinia } from '@pinia/testing';
+import { useWorkflowsStore } from '@/stores';
+
+let pinia: ReturnType<typeof createTestingPinia>;
+beforeAll(() => {
+	pinia = createTestingPinia();
+});
+
+describe('workflowHelpers', () => {
+	describe('shouldReplaceInputDataWithPinData', () => {
+		beforeEach(() => {
+			pinia.state.value = {
+				workflows: useWorkflowsStore(),
+			};
+		});
+
+		it('should return true if no active execution is set', () => {
+			const result = shouldReplaceInputDataWithPinData();
+			expect(result).toBe(true);
+		});
+
+		it('should return true if active execution is set and mode is manual', async () => {
+			pinia.state.value.workflows.activeWorkflowExecution = { mode: 'manual' };
+
+			const result = shouldReplaceInputDataWithPinData();
+			expect(result).toBe(true);
+		});
+
+		it('should return false if active execution is set and mode is not manual', async () => {
+			pinia.state.value.workflows.activeWorkflowExecution = { mode: 'webhook' };
+
+			const result = shouldReplaceInputDataWithPinData();
+			expect(result).toBe(false);
+		});
+	});
+});

packages/editor-ui/src/mixins/workflowHelpers.ts

@@ -189,6 +189,15 @@ function getNodeTypes(): INodeTypes {
 	return useWorkflowsStore().getNodeTypes();
 }
 
+export function shouldReplaceInputDataWithPinData() {
+	const workflowsStore = useWorkflowsStore();
+	return (
+		!workflowsStore.activeWorkflowExecution ||
+		(workflowsStore.activeWorkflowExecution &&
+			workflowsStore.activeWorkflowExecution.mode === 'manual')
+	);
+}
+
 // Returns connectionInputData to be able to execute an expression.
 function connectionInputData(
 	parentNode: string[],
@@ -223,32 +232,36 @@ function connectionInputData(
 		}
 	}
 
-	const parentPinData = parentNode.reduce((acc: INodeExecutionData[], parentNodeName, index) => {
-		const pinData = useWorkflowsStore().pinDataByNodeName(parentNodeName);
+	const workflowsStore = useWorkflowsStore();
 
-		if (pinData) {
-			acc.push({
-				json: pinData[0],
-				pairedItem: {
-					item: index,
-					input: 1,
-				},
-			});
-		}
+	if (shouldReplaceInputDataWithPinData()) {
+		const parentPinData = parentNode.reduce((acc: INodeExecutionData[], parentNodeName, index) => {
+			const pinData = workflowsStore.pinDataByNodeName(parentNodeName);
 
-		return acc;
-	}, []);
+			if (pinData) {
+				acc.push({
+					json: pinData[0],
+					pairedItem: {
+						item: index,
+						input: 1,
+					},
+				});
+			}
 
-	if (parentPinData.length > 0) {
-		if (connectionInputData && connectionInputData.length > 0) {
-			parentPinData.forEach((parentPinDataEntry) => {
-				connectionInputData![0].json = {
-					...connectionInputData![0].json,
-					...parentPinDataEntry.json,
-				};
-			});
-		} else {
-			connectionInputData = parentPinData;
+			return acc;
+		}, []);
+
+		if (parentPinData.length > 0) {
+			if (connectionInputData && connectionInputData.length > 0) {
+				parentPinData.forEach((parentPinDataEntry) => {
+					connectionInputData![0].json = {
+						...connectionInputData![0].json,
+						...parentPinDataEntry.json,
+					};
+				});
+			} else {
+				connectionInputData = parentPinData;
+			}
 		}
 	}
 
@@ -271,21 +284,24 @@ function executeData(
 		// Add the input data to be able to also resolve the short expression format
 		// which does not use the node name
 		const parentNodeName = parentNode[0];
+		const workflowsStore = useWorkflowsStore();
 
-		const parentPinData = useWorkflowsStore().getPinData![parentNodeName];
+		if (shouldReplaceInputDataWithPinData()) {
+			const parentPinData = workflowsStore.getPinData![parentNodeName];
 
-		// populate `executeData` from `pinData`
+			// populate `executeData` from `pinData`
 
-		if (parentPinData) {
-			executeData.data = { main: [parentPinData] };
-			executeData.source = { main: [{ previousNode: parentNodeName }] };
+			if (parentPinData) {
+				executeData.data = { main: [parentPinData] };
+				executeData.source = { main: [{ previousNode: parentNodeName }] };
 
-			return executeData;
+				return executeData;
+			}
 		}
 
 		// populate `executeData` from `runData`
 
-		const workflowRunData = useWorkflowsStore().getWorkflowRunData;
+		const workflowRunData = workflowsStore.getWorkflowRunData;
 		if (workflowRunData === null) {
 			return executeData;
 		}

packages/editor-ui/src/views/NodeView.vue

@@ -3604,6 +3604,8 @@ export default defineComponent({
 							type: 'error',
 						});
 					}
+				} else if (json && json.command === 'setActiveExecution') {
+					this.workflowsStore.activeWorkflowExecution = json.execution;
 				}
 			} catch (e) {}
 		},