Browse Source

Modify process group workerGroup value display and filter child node duplicate values

pull/3/MERGE
break60 5 years ago
parent
commit
d4ef2293df
  1. 3
      dolphinscheduler-ui/src/js/conf/home/pages/dag/_source/dag.vue
  2. 13
      dolphinscheduler-ui/src/js/conf/home/pages/dag/_source/formModel/formModel.vue
  3. 7
      dolphinscheduler-ui/src/js/conf/home/pages/dag/_source/formModel/tasks/sub_process.vue
  4. 2
      dolphinscheduler-ui/src/js/conf/home/pages/projects/pages/instance/pages/list/_source/list.vue

3
dolphinscheduler-ui/src/js/conf/home/pages/dag/_source/dag.vue

@ -581,7 +581,8 @@
taskType: type, taskType: type,
self: self, self: self,
preNode: preNode, preNode: preNode,
rearList: rearList rearList: rearList,
instanceId: this.$route.params.id
} }
}) })
}) })

13
dolphinscheduler-ui/src/js/conf/home/pages/dag/_source/formModel/formModel.vue

@ -268,6 +268,7 @@
</template> </template>
<script> <script>
import _ from 'lodash' import _ from 'lodash'
import { mapActions } from 'vuex'
import mLog from './log' import mLog from './log'
import mMr from './tasks/mr' import mMr from './tasks/mr'
import mSql from './tasks/sql' import mSql from './tasks/sql'
@ -356,9 +357,11 @@
taskType: String, taskType: String,
self: Object, self: Object,
preNode: Array, preNode: Array,
rearList: Array rearList: Array,
instanceId: Number
}, },
methods: { methods: {
...mapActions('dag', ['getTaskInstanceList']),
/** /**
* depend * depend
*/ */
@ -633,8 +636,12 @@
break; break;
} }
} }
if(!hasMatch && o.workerGroupId!=undefined){ if(o.workerGroup == undefined) {
this.workerGroup = 'default' this.store.dispatch('dag/getTaskInstanceList',{
pageSize: 10, pageNo: 1, processInstanceId: this.instanceId, name: o.name
}).then(res => {
this.workerGroup = res.totalList[0].workerGroup
})
} else { } else {
this.workerGroup = o.workerGroup this.workerGroup = o.workerGroup
} }

7
dolphinscheduler-ui/src/js/conf/home/pages/dag/_source/formModel/tasks/sub_process.vue

@ -95,7 +95,12 @@
}, },
created () { created () {
let processListS = _.cloneDeep(this.store.state.dag.processListS) let processListS = _.cloneDeep(this.store.state.dag.processListS)
let id = this.router.history.current.params.id || null let id = null
if(this.router.history.current.name==='projects-instance-details') {
id = this.router.history.current.query.id || null
} else {
id = this.router.history.current.params.id || null
}
this.processDefinitionList = (() => { this.processDefinitionList = (() => {
let a = _.map(processListS, v => { let a = _.map(processListS, v => {
return { return {

2
dolphinscheduler-ui/src/js/conf/home/pages/projects/pages/instance/pages/list/_source/list.vue

@ -70,7 +70,7 @@
<span>{{parseInt(pageNo === 1 ? ($index + 1) : (($index + 1) + (pageSize * (pageNo - 1))))}}</span> <span>{{parseInt(pageNo === 1 ? ($index + 1) : (($index + 1) + (pageSize * (pageNo - 1))))}}</span>
</td> </td>
<td style="min-width: 200px;max-width: 300px;padding-right: 10px;"> <td style="min-width: 200px;max-width: 300px;padding-right: 10px;">
<span class="ellipsis" style="padding-left: 4px;"><router-link :to="{ path: '/projects/instance/list/' + item.id}" tag="a" class="links" :title="item.name">{{item.name}}</router-link></span> <span class="ellipsis" style="padding-left: 4px;"><router-link :to="{ path: '/projects/instance/list/' + item.id , query:{id: item.processDefinitionId}}" tag="a" class="links" :title="item.name">{{item.name}}</router-link></span>
</td> </td>
<td> <td>
<span v-html="_rtState(item.state)" style="cursor: pointer;"></span> <span v-html="_rtState(item.state)" style="cursor: pointer;"></span>

Loading…
Cancel
Save