-
{{$t('运行标志')}}
+
{{$t('Run flag')}}
@@ -48,10 +47,9 @@
- {{$t('描述')}}
+ {{$t('Description')}}
-
@@ -69,28 +67,30 @@
- {{$t('任务优先级')}}
+ {{$t('Task priority')}}
-
+
+
+
+ Worker分组
+
- {{$t('失败重试次数')}}
+ {{$t('Number of failed retries')}}
- ({{$t('次')}})
- {{$t('失败重试间隔')}}
+ ({{$t('Times')}})
+ {{$t('Failed retry interval')}}
- ({{$t('分')}})
+ ({{$t('Minute')}})
@@ -128,6 +128,7 @@
v-if="taskType === 'SQL'"
@on-params="_onParams"
ref="SQL"
+ :create-node-id="id"
:backfill-item="backfillItem">
@@ -163,8 +164,8 @@
- {{$t('取消')}}
- {{spinnerLoading ? 'Loading...' : $t('确认添加')}}
+ {{$t('Cancel')}}
+ {{spinnerLoading ? 'Loading...' : $t('Confirm add')}}
@@ -178,15 +179,16 @@
import mShell from './tasks/shell'
import mSpark from './tasks/spark'
import mPython from './tasks/python'
- import { isNameExDag,rtBantpl } from './../plugIn/util'
import JSP from './../plugIn/jsPlumbHandle'
import mProcedure from './tasks/procedure'
import mDependent from './tasks/dependent'
import mSubProcess from './tasks/sub_process'
import mSelectInput from './_source/selectInput'
import mTimeoutAlarm from './_source/timeoutAlarm'
+ import mWorkerGroups from './_source/workerGroups'
import clickoutside from '@/module/util/clickoutside'
import disabledState from '@/module/mixin/disabledState'
+ import { isNameExDag, rtBantpl } from './../plugIn/util'
import mPriority from '@/module/components/priority/priority'
export default {
@@ -218,7 +220,9 @@
// Task timeout alarm
timeout: {},
// Task priority
- taskInstancePriority: 'MEDIUM'
+ taskInstancePriority: 'MEDIUM',
+ // worker group id
+ workerGroupId: -1
}
},
/**
@@ -255,7 +259,7 @@
*/
_seeHistory () {
this.self.$router.push({
- name: 'task-instance-list',
+ name: 'task-instance',
query: {
processInstanceId: this.self.$route.params.id,
taskName: this.backfillItem.name
@@ -269,13 +273,13 @@
*/
_goSubProcess () {
if (_.isEmpty(this.backfillItem)) {
- this.$message.warning(`${i18n.$t('新创建子工作流还未执行,不能进入子工作流')}`)
+ this.$message.warning(`${i18n.$t('The newly created sub-Process has not yet been executed and cannot enter the sub-Process')}`)
return
}
if (this.router.history.current.name === 'projects-instance-details') {
let stateId = $(`#${this.id}`).attr('data-state-id') || null
if (!stateId) {
- this.$message.warning(`${i18n.$t('该任务还未执行,不能进入子工作流')}`)
+ this.$message.warning(`${i18n.$t('The task has not been executed and cannot enter the sub-Process')}`)
return
}
this.store.dispatch('dag/getSubProcessId', { taskId: stateId }).then(res => {
@@ -304,7 +308,7 @@
*/
_verifName () {
if (!_.trim(this.name)) {
- this.$message.warning(`${i18n.$t('请输入名称(必填)')}`)
+ this.$message.warning(`${i18n.$t('Please enter name (required)')}`)
return false
}
if (this.name === this.backfillItem.name) {
@@ -312,7 +316,7 @@
}
// Name repeat depends on dom backfill dependent store
if (isNameExDag(this.name, _.isEmpty(this.backfillItem) ? 'dom' : 'backfill')) {
- this.$message.warning(`${i18n.$t('名称已存在请重新输入')}`)
+ this.$message.warning(`${i18n.$t('Name already exists')}`)
return false
}
return true
@@ -349,10 +353,14 @@
maxRetryTimes: this.maxRetryTimes,
retryInterval: this.retryInterval,
timeout: this.timeout,
- taskInstancePriority: this.taskInstancePriority
+ taskInstancePriority: this.taskInstancePriority,
+ workerGroupId: this.workerGroupId
},
fromThis: this
})
+
+ // set run flag
+ this._setRunFlag()
},
/**
* Sub-workflow selected node echo name
@@ -360,6 +368,16 @@
_onSetProcessName (name) {
this.name = name
},
+ /**
+ * set run flag
+ */
+ _setRunFlag () {
+ let dom = $(`#${this.id}`).find('.ban-p')
+ dom.html('')
+ if (this.runFlag === 'FORBIDDEN') {
+ dom.append(rtBantpl())
+ }
+ },
/**
* Submit verification
*/
@@ -384,13 +402,7 @@
}
},
watch: {
- runFlag(val){
- let dom = $(`#${this.id}`).find('.ban-p')
- dom.html('')
- if (val === 'FORBIDDEN') {
- dom.append(rtBantpl())
- }
- }
+
},
created () {
// Unbind copy and paste events
@@ -413,11 +425,14 @@
this.desc = o.desc
this.maxRetryTimes = o.maxRetryTimes
this.retryInterval = o.retryInterval
+ this.workerGroupId = o.workerGroupId
}
}
this.isContentBox = true
},
- mounted () {},
+ mounted () {
+
+ },
updated () {
},
beforeDestroy () {
@@ -444,119 +459,12 @@
mDependent,
mSelectInput,
mTimeoutAlarm,
- mPriority
+ mPriority,
+ mWorkerGroups
}
}
diff --git a/escheduler-ui/src/js/conf/home/pages/dag/_source/formModel/log.vue b/escheduler-ui/src/js/conf/home/pages/dag/_source/formModel/log.vue
index 28896f9366..6f7ce8481b 100644
--- a/escheduler-ui/src/js/conf/home/pages/dag/_source/formModel/log.vue
+++ b/escheduler-ui/src/js/conf/home/pages/dag/_source/formModel/log.vue
@@ -10,18 +10,18 @@
-
{{$t('查看日志')}}
+
{{$t('View log')}}
@@ -32,7 +32,7 @@
- {{$t('关闭')}}
+ {{$t('Close')}}
@@ -88,13 +88,13 @@
setTimeout(() => {
this.loading = false
if (res.data) {
- this.$message.success(`${i18n.$t('更新日志成功')}`)
+ this.$message.success(`${i18n.$t('Update log success')}`)
} else {
- this.$message.warning(`${i18n.$t('暂无更多日志')}`)
+ this.$message.warning(`${i18n.$t('No more logs')}`)
}
}, 1500)
// Handling text field size
- handerTextareaSize().html('').text(res.data || `${i18n.$t('暂无日志')}`)
+ handerTextareaSize().html('').text(res.data || `${i18n.$t('No log')}`)
}).catch(e => {
this.$message.error(e.msg || '')
this.loading = false
@@ -108,15 +108,15 @@
if (!res.data) {
this.isData = false
setTimeout(() => {
- this.$message.warning(`${i18n.$t('暂无更多日志')}`)
+ this.$message.warning(`${i18n.$t('No more logs')}`)
}, 1000)
// Handling text field size
- handerTextareaSize().html('').text(content || `${i18n.$t('暂无日志')}`)
+ handerTextareaSize().html('').text(content || `${i18n.$t('No log')}`)
} else {
this.isData = true
content = res.data
// Handling text field size
- handerTextareaSize().html('').text(content || `${i18n.$t('暂无日志')}`)
+ handerTextareaSize().html('').text(content || `${i18n.$t('No log')}`)
setTimeout(() => {
$('#textarea').scrollTop(2)
@@ -189,7 +189,7 @@
if (($this.scrollTop() + $this.height()) === $this.height()) {
if (self.loadingIndex > 0) {
self.$message.loading({
- content: `${i18n.$t('正在努力请求日志中...')}`,
+ content: `${i18n.$t('Loading Log...')}`,
duration: 0,
closable: false
})
@@ -201,7 +201,7 @@
// No data is not requested
if (self.isData) {
self.$message.loading({
- content: `${i18n.$t('正在努力请求日志中...')}`,
+ content: `${i18n.$t('Loading Log...')}`,
duration: 0,
closable: false
})
@@ -226,7 +226,7 @@
// Source is a task instance
if (this.source === 'list') {
this.$message.loading({
- content: `${i18n.$t('正在努力请求日志中...')}`,
+ content: `${i18n.$t('Loading Log...')}`,
duration: 0,
closable: false
})
diff --git a/escheduler-ui/src/js/conf/home/pages/dag/_source/formModel/tasks/_source/commcon.js b/escheduler-ui/src/js/conf/home/pages/dag/_source/formModel/tasks/_source/commcon.js
index 7a143fb0cf..389ac6f603 100644
--- a/escheduler-ui/src/js/conf/home/pages/dag/_source/formModel/tasks/_source/commcon.js
+++ b/escheduler-ui/src/js/conf/home/pages/dag/_source/formModel/tasks/_source/commcon.js
@@ -7,19 +7,19 @@ import i18n from '@/module/i18n'
const cycleList = [
{
value: 'month',
- label: `${i18n.$t('月')}`
+ label: `${i18n.$t('month')}`
},
{
value: 'week',
- label: `${i18n.$t('周')}`
+ label: `${i18n.$t('week')}`
},
{
value: 'day',
- label: `${i18n.$t('日')}`
+ label: `${i18n.$t('day')}`
},
{
value: 'hour',
- label: `${i18n.$t('时')}`
+ label: `${i18n.$t('hour')}`
}
]
@@ -30,81 +30,81 @@ const dateValueList = {
'hour': [
{
value: 'last1Hour',
- label: `${i18n.$t('前1小时')}`
+ label: `${i18n.$t('Last1Hour')}`
},
{
value: 'last2Hours',
- label: `${i18n.$t('前2小时')}`
+ label: `${i18n.$t('Last2Hours')}`
},
{
value: 'last3Hours',
- label: `${i18n.$t('前3小时')}`
+ label: `${i18n.$t('Last3Hours')}`
}
],
'day': [
{
value: 'last1Days',
- label: `${i18n.$t('昨天')}`
+ label: `${i18n.$t('Last1Days')}`
},
{
value: 'last2Days',
- label: `${i18n.$t('前两天')}`
+ label: `${i18n.$t('Last2Days')}`
},
{
value: 'last3Days',
- label: `${i18n.$t('前三天')}`
+ label: `${i18n.$t('Last3Days')}`
},
{
value: 'last7Days',
- label: `${i18n.$t('前七天')}`
+ label: `${i18n.$t('Last7Days')}`
}
],
'week': [
{
value: 'lastWeek',
- label: `${i18n.$t('上周')}`
+ label: `${i18n.$t('LastWeek')}`
},
{
value: 'lastMonday',
- label: `${i18n.$t('上周一')}`
+ label: `${i18n.$t('LastMonday')}`
},
{
value: 'lastTuesday',
- label: `${i18n.$t('上周二')}`
+ label: `${i18n.$t('LastTuesday')}`
},
{
value: 'lastWednesday',
- label: `${i18n.$t('上周三')}`
+ label: `${i18n.$t('LastWednesday')}`
},
{
value: 'lastThursday',
- label: `${i18n.$t('上周四')}`
+ label: `${i18n.$t('LastThursday')}`
},
{
value: 'lastFriday',
- label: `${i18n.$t('上周五')}`
+ label: `${i18n.$t('LastFriday')}`
},
{
value: 'lastSaturday',
- label: `${i18n.$t('上周六')}`
+ label: `${i18n.$t('LastSaturday')}`
},
{
value: 'lastSunday',
- label: `${i18n.$t('上周日')}`
+ label: `${i18n.$t('LastSunday')}`
}
],
'month': [
{
value: 'lastMonth',
- label: `${i18n.$t('上月')}`
+ label: `${i18n.$t('LastMonth')}`
},
{
value: 'lastMonthBegin',
- label: `${i18n.$t('上月初')}`
+ label: `${i18n.$t('LastMonthBegin')}`
},
{
value: 'lastMonthEnd',
- label: `${i18n.$t('上月末')}`
+ label: `${i18n.$t('LastMonthEnd')}`
}
]
}
@@ -182,11 +182,11 @@ const typeList = [
const sqlTypeList = [
{
id: 0,
- code: `${i18n.$t('查询')}`
+ code: `${i18n.$t('Query')}`
},
{
id: 1,
- code: `${i18n.$t('非查询')}`
+ code: `${i18n.$t('Non Query')}`
}
]
diff --git a/escheduler-ui/src/js/conf/home/pages/dag/_source/formModel/tasks/_source/datasource.vue b/escheduler-ui/src/js/conf/home/pages/dag/_source/formModel/tasks/_source/datasource.vue
index 0427dbffff..0023051119 100644
--- a/escheduler-ui/src/js/conf/home/pages/dag/_source/formModel/tasks/_source/datasource.vue
+++ b/escheduler-ui/src/js/conf/home/pages/dag/_source/formModel/tasks/_source/datasource.vue
@@ -12,7 +12,7 @@
:label="city.code">
-