natas_hw
/
dolphinscheduler
0
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[improvement][UI][2.0.9] Speed up the refresh of task status in process instance (#13587) 

* [Improvement][UI][2.0.x] Speed up the refresh of task status in process instance

* [Improvement][UI][2.0.x] Speed up the refresh of task status in process instance

---------

Co-authored-by: lile <lile@boimc.com>
This commit is contained in:
ll 2023-02-22 10:26:12 +08:00 committed by GitHub
parent a10483fb5a
commit 33e345fe99
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 28 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
dolphinscheduler-ui/src/js/conf/home/pages/dag/_source/dag.vue
View File

@ -157,7 +157,9 @@
// log dialog
logDialog: false,
logTaskInstance: null,
taskInstances: []
taskInstances: [],
// incremental comparison after the first refresh
lastStatues: new Map()
}
},
mounted () {
@ -182,11 +184,13 @@
// refresh task status
if (this.type === 'instance') {
this.refreshTaskStatus()
// status polling
this.statusTimer = setInterval(() => {
this.refreshTaskStatus()
}, 90000)
this.refreshTaskStatus(() => {
// set the timer after the first refresh
// status polling
this.statusTimer = setInterval(() => {
this.refreshTaskStatus()
}, 90000)
})
}
},
beforeDestroy () {
@ -558,7 +562,7 @@
/**
* Task status
*/
refreshTaskStatus () {
refreshTaskStatus (callback = undefined) {
const instanceId = this.$route.params.id
this.loading(true)
this.getTaskState(instanceId)
@ -569,11 +573,20 @@
if (taskList) {
this.taskInstances = taskList
taskList.forEach((taskInstance) => {
this.$refs.canvas.setNodeStatus({
code: taskInstance.taskCode,
state: taskInstance.state,
taskInstance
})
const lastStatus = this.lastStatues.get(taskInstance.taskCode)
if (!lastStatus ||
(lastStatus.host !== taskInstance.host) ||
(lastStatus.retryTimes !== taskInstance.retryTimes) ||
(lastStatus.submitTime !== taskInstance.submitTime) ||
(lastStatus.startTime !== taskInstance.startTime) ||
(lastStatus.endTime !== taskInstance.endTime)) {
this.lastStatues.set(taskInstance.taskCode, taskInstance)
this.$refs.canvas.setNodeStatus({
code: taskInstance.taskCode,
state: taskInstance.state,
taskInstance
})
}
})
}
if (list) {
@ -586,6 +599,9 @@
})
.finally(() => {
this.loading(false)
if (callback) {
callback()
}
})
},
/**