This is an automated email from the ASF dual-hosted git repository.
leonbao pushed a commit to branch 1.3.2-release
in repository https://gitbox.apache.org/repos/asf/incubator-dolphinscheduler.git
The following commit(s) were added to refs/heads/1.3.2-release by this push:
new c30713d Update actions.js (#3401)
c30713d is described below
commit c30713d88c8500ad65ab5aecd3c49aa64a57e68f
Author: JinyLeeChina <[email protected]>
AuthorDate: Wed Aug 5 18:59:49 2020 +0800
Update actions.js (#3401)
---
.../src/js/conf/home/store/dag/actions.js | 23 ++++++++++++++++++++--
1 file changed, 21 insertions(+), 2 deletions(-)
diff --git a/dolphinscheduler-ui/src/js/conf/home/store/dag/actions.js
b/dolphinscheduler-ui/src/js/conf/home/store/dag/actions.js
index f933eae..a549aaf 100644
--- a/dolphinscheduler-ui/src/js/conf/home/store/dag/actions.js
+++ b/dolphinscheduler-ui/src/js/conf/home/store/dag/actions.js
@@ -19,6 +19,25 @@ import _ from 'lodash'
import io from '@/module/io'
import { tasksState } from '@/conf/home/pages/dag/_source/config'
+// delete 'definitionList' from tasks
+const deleteDefinitionList = (tasks) => {
+ const newTasks = [];
+ tasks.forEach(item => {
+ const newItem = Object.assign({}, item);
+ if(newItem.dependence && newItem.dependence.dependTaskList) {
+ newItem.dependence.dependTaskList.forEach(dependTaskItem => {
+ if (dependTaskItem.dependItemList) {
+ dependTaskItem.dependItemList.forEach(dependItem => {
+ Reflect.deleteProperty(dependItem, 'definitionList');
+ })
+ }
+ })
+ }
+ newTasks.push(newItem);
+ });
+ return newTasks;
+}
+
export default {
/**
* Task status acquisition
@@ -193,7 +212,7 @@ export default {
return new Promise((resolve, reject) => {
const data = {
globalParams: state.globalParams,
- tasks: state.tasks,
+ tasks: deleteDefinitionList(state.tasks),
tenantId: state.tenantId,
timeout: state.timeout
}
@@ -217,7 +236,7 @@ export default {
return new Promise((resolve, reject) => {
const data = {
globalParams: state.globalParams,
- tasks: state.tasks,
+ tasks: deleteDefinitionList(state.tasks),
tenantId: state.tenantId,
timeout: state.timeout
}