mirror of
https://gitee.com/dolphinscheduler/DolphinScheduler.git
synced 2024-12-05 05:38:30 +08:00
Merge remote-tracking branch 'upstream/dev-1.1.0' into dev-1.1.0
This commit is contained in:
commit
88d82b27dc
@ -21,9 +21,11 @@
|
||||
</div>
|
||||
</div>
|
||||
<div class="clearfix list">
|
||||
<x-button type="info" style="margin-left:20px" shape="circle" :loading="spinnerLoading" @click="preview()" v-ps="['GENERAL_USER']">执行时间</x-button>
|
||||
<div class="text">
|
||||
{{$t('Timing')}}
|
||||
</div>
|
||||
|
||||
<div class="cont">
|
||||
<template>
|
||||
<x-poptip :ref="'poptip'" placement="bottom-start">
|
||||
@ -43,6 +45,13 @@
|
||||
</template>
|
||||
</div>
|
||||
</div>
|
||||
<div class="clearfix list">
|
||||
<div style = "padding-left: 150px;">未来五次执行时间</div>
|
||||
<ul style = "padding-left: 150px;">
|
||||
<li v-for="time in previewTimes">{{time}}</li>
|
||||
</ul>
|
||||
</div>
|
||||
|
||||
<div class="clearfix list">
|
||||
<div class="text">
|
||||
{{$t('Failure Strategy')}}
|
||||
@ -162,7 +171,8 @@
|
||||
receiversCc: [],
|
||||
i18n: i18n.globalScope.LOCALE,
|
||||
processInstancePriority: 'MEDIUM',
|
||||
workerGroupId: -1
|
||||
workerGroupId: -1,
|
||||
previewTimes: []
|
||||
}
|
||||
},
|
||||
props: {
|
||||
@ -225,6 +235,29 @@
|
||||
}
|
||||
},
|
||||
|
||||
_preview () {
|
||||
if (this._verification()) {
|
||||
let api = 'dag/previewSchedule'
|
||||
let searchParams = {
|
||||
schedule: JSON.stringify({
|
||||
startTime: this.scheduleTime[0],
|
||||
endTime: this.scheduleTime[1],
|
||||
crontab: this.crontab
|
||||
})
|
||||
}
|
||||
let msg = ''
|
||||
|
||||
this.store.dispatch(api, searchParams).then(res => {
|
||||
this.previewTimes = res
|
||||
if (this.previewTimes.length) {
|
||||
resolve()
|
||||
} else {
|
||||
reject(new Error(0))
|
||||
}
|
||||
})
|
||||
}
|
||||
},
|
||||
|
||||
_getNotifyGroupList () {
|
||||
return new Promise((resolve, reject) => {
|
||||
let notifyGroupListS = _.cloneDeep(this.store.state.dag.notifyGroupListS) || []
|
||||
@ -248,6 +281,9 @@
|
||||
},
|
||||
close () {
|
||||
this.$emit('close')
|
||||
},
|
||||
preview () {
|
||||
this._preview()
|
||||
}
|
||||
},
|
||||
watch: {
|
||||
|
@ -383,6 +383,19 @@ export default {
|
||||
})
|
||||
})
|
||||
},
|
||||
/**
|
||||
* Preview timing
|
||||
*/
|
||||
previewSchedule ({ state }, payload) {
|
||||
return new Promise((resolve, reject) => {
|
||||
io.post(`projects/${state.projectName}/schedule/preview`, payload, res => {
|
||||
resolve(res.data)
|
||||
//alert(res.data)
|
||||
}).catch(e => {
|
||||
reject(e)
|
||||
})
|
||||
})
|
||||
},
|
||||
/**
|
||||
* Timing list paging
|
||||
*/
|
||||
|
Loading…
Reference in New Issue
Block a user