Revert "enable stale data in execution run"

8edb68dbff
This commit is contained in:
Mutasem 2022-03-31 11:28:27 +02:00
parent 8edb68dbff
commit 8fe417afe4
3 changed files with 7 additions and 34 deletions

View file

@ -98,12 +98,6 @@ declare module 'jsplumb' {
} }
} }
declare module 'n8n-workflow' {
export interface ITaskData {
updatedAt?: number;
}
}
// EndpointOptions from jsplumb seems incomplete and wrong so we define an own one // EndpointOptions from jsplumb seems incomplete and wrong so we define an own one
export interface IEndpointOptions { export interface IEndpointOptions {
anchor?: any; // tslint:disable-line:no-any anchor?: any; // tslint:disable-line:no-any
@ -968,7 +962,7 @@ export type IFormBoxConfig = {
export interface ITab { export interface ITab {
value: string | number; value: string | number;
label?: string; label?: string;
href?: string; href?: string,
icon?: string; icon?: string;
align?: 'right'; align?: 'right';
} };

View file

@ -270,6 +270,7 @@ export default mixins(
MAX_DISPLAY_ITEMS_AUTO_ALL, MAX_DISPLAY_ITEMS_AUTO_ALL,
currentPage: 1, currentPage: 1,
pageSize: 10, pageSize: 10,
staleData: false,
}; };
}, },
mounted() { mounted() {
@ -311,7 +312,7 @@ export default mixins(
node (): INodeUi | null { node (): INodeUi | null {
return this.$store.getters.activeNode; return this.$store.getters.activeNode;
}, },
runTaskData(): ITaskData | null { runMetadata () {
if (!this.node || this.workflowExecution === null) { if (!this.node || this.workflowExecution === null) {
return null; return null;
} }
@ -326,28 +327,12 @@ export default mixins(
return null; return null;
} }
return runData[this.node.name][this.runIndex]; const taskData: ITaskData = runData[this.node.name][this.runIndex];
},
runMetadata (): {executionTime: number, startTime: string} | null {
if (!this.runTaskData) {
return null;
}
return { return {
executionTime: this.runTaskData.executionTime, executionTime: taskData.executionTime,
startTime: new Date(this.runTaskData.startTime).toLocaleString(), startTime: new Date(taskData.startTime).toLocaleString(),
}; };
}, },
staleData (): boolean {
if (!this.node || !this.runTaskData || !this.runTaskData.updatedAt) {
return false;
}
const updatedAt = this.runTaskData.updatedAt;
const runAt = this.runTaskData.startTime;
return updatedAt > runAt;
},
dataCount (): number { dataCount (): number {
return this.getDataCount(this.runIndex, this.outputIndex); return this.getDataCount(this.runIndex, this.outputIndex);
}, },

View file

@ -470,12 +470,6 @@ export const store = new Vuex.Store({
state.stateIsDirty = true; state.stateIsDirty = true;
Vue.set(node, 'parameters', updateInformation.value); Vue.set(node, 'parameters', updateInformation.value);
if (state.workflowExecutionData && state.workflowExecutionData.data.resultData.runData[node.name]) {
const nodeRuns = state.workflowExecutionData.data.resultData.runData[node.name];
nodeRuns.forEach((node) => {
Vue.set(node, 'updatedAt', new Date().getTime());
});
}
}, },
// Node-Index // Node-Index