admin/n8n-enterprise-unlocked
1
0
Fork 0
mirror of https://github.com/Abdulazizzn/n8n-enterprise-unlocked.git synced 2025-12-19 19:11:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

perf(editor): Introduce execution data throttling for logs and canvas updates (no-changelog) (#18812)

Browse Source
This commit is contained in:
Alex Grozav
2025-08-26 16:01:15 +01:00
committed by GitHub
parent af2157f384
commit f5719371b1
3 changed files with 25 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
packages/frontend/editor-ui/src/composables/useCanvasMapping.ts
View File

@@ -7,7 +7,7 @@ import { useI18n } from '@n8n/i18n';
import { useNodeTypesStore } from '@/stores/nodeTypes.store'; import { useNodeTypesStore } from '@/stores/nodeTypes.store';
import { useWorkflowsStore } from '@/stores/workflows.store'; import { useWorkflowsStore } from '@/stores/workflows.store';
import type { Ref } from 'vue'; import type { Ref } from 'vue';
import { computed } from 'vue'; import { ref, computed } from 'vue';
import type { import type {
BoundingBox, BoundingBox,
CanvasConnection, CanvasConnection,
@@ -46,6 +46,7 @@ import {
} from 'n8n-workflow'; } from 'n8n-workflow';
import type { INodeUi } from '@/Interface'; import type { INodeUi } from '@/Interface';
import { import {
CANVAS_EXECUTION_DATA_THROTTLE_DURATION,
CUSTOM_API_CALL_KEY, CUSTOM_API_CALL_KEY,
FORM_NODE_TYPE, FORM_NODE_TYPE,
SIMULATE_NODE_TYPE, SIMULATE_NODE_TYPE,
@@ -60,6 +61,7 @@ import { getTriggerNodeServiceName } from '@/utils/nodeTypesUtils';
import { useNodeDirtiness } from '@/composables/useNodeDirtiness'; import { useNodeDirtiness } from '@/composables/useNodeDirtiness';
import { getNodeIconSource } from '../utils/nodeIcon'; import { getNodeIconSource } from '../utils/nodeIcon';
import * as workflowUtils from 'n8n-workflow/common'; import * as workflowUtils from 'n8n-workflow/common';
import { throttledWatch } from '@vueuse/core';
export function useCanvasMapping({ export function useCanvasMapping({
nodes, nodes,
@@ -355,9 +357,14 @@ export function useCanvasMapping({
}, {}), }, {}),
); );
const nodeExecutionRunDataOutputMapById = computed(() => const nodeExecutionRunDataOutputMapById = ref<Record<string, ExecutionOutputMap>>({});
Object.keys(nodeExecutionRunDataById.value).reduce<Record<string, ExecutionOutputMap>>(
(acc, nodeId) => { throttledWatch(
nodeExecutionRunDataById,
(value) => {
nodeExecutionRunDataOutputMapById.value = Object.keys(value).reduce<
Record<string, ExecutionOutputMap>
>((acc, nodeId) => {
acc[nodeId] = {}; acc[nodeId] = {};
const outputData = { iterations: 0, total: 0 }; const outputData = { iterations: 0, total: 0 };
@@ -383,9 +390,9 @@ export function useCanvasMapping({
} }
return acc; return acc;
}, {});
}, },
{}, { throttle: CANVAS_EXECUTION_DATA_THROTTLE_DURATION, immediate: true },
),
); );
const nodeIssuesById = computed(() => const nodeIssuesById = computed(() =>

7
packages/frontend/editor-ui/src/constants.ts
View File

@@ -984,3 +984,10 @@ export const AI_NODES_PACKAGE_NAME = '@n8n/n8n-nodes-langchain';
export const AI_ASSISTANT_MAX_CONTENT_LENGTH = 100; // in kilobytes export const AI_ASSISTANT_MAX_CONTENT_LENGTH = 100; // in kilobytes
export const RUN_DATA_DEFAULT_PAGE_SIZE = 25; export const RUN_DATA_DEFAULT_PAGE_SIZE = 25;
/**
* Performance Optimizations
*/
export const LOGS_EXECUTION_DATA_THROTTLE_DURATION = 1000;
export const CANVAS_EXECUTION_DATA_THROTTLE_DURATION = 500;

6
packages/frontend/editor-ui/src/features/logs/composables/useLogsExecutionData.ts
View File

@@ -9,7 +9,7 @@ import { parse } from 'flatted';
import { useToast } from '@/composables/useToast'; import { useToast } from '@/composables/useToast';
import type { LatestNodeInfo, LogEntry } from '../logs.types'; import type { LatestNodeInfo, LogEntry } from '../logs.types';
import { isChatNode } from '@/utils/aiUtils'; import { isChatNode } from '@/utils/aiUtils';
import { PLACEHOLDER_EMPTY_WORKFLOW_ID } from '@/constants'; import { LOGS_EXECUTION_DATA_THROTTLE_DURATION, PLACEHOLDER_EMPTY_WORKFLOW_ID } from '@/constants';
export function useLogsExecutionData() { export function useLogsExecutionData() {
const nodeHelpers = useNodeHelpers(); const nodeHelpers = useNodeHelpers();
@@ -62,7 +62,9 @@ export function useLogsExecutionData() {
); );
}); });
const updateInterval = computed(() => ((entries.value?.length ?? 0) > 1 ? 1000 : 0)); const updateInterval = computed(() =>
(entries.value?.length ?? 0) > 1 ? LOGS_EXECUTION_DATA_THROTTLE_DURATION : 0,
);
function resetExecutionData() { function resetExecutionData() {
execData.value = undefined; execData.value = undefined;