diff --git a/dolphinscheduler-ui/src/views/projects/task/components/node/fields/index.ts b/dolphinscheduler-ui/src/views/projects/task/components/node/fields/index.ts index 6691d67dbe4ef0d1c7772c19992025d6b6bed8bf..d1e2e2b3a21b53b72ee8782de6c439cd343b0172 100644 --- a/dolphinscheduler-ui/src/views/projects/task/components/node/fields/index.ts +++ b/dolphinscheduler-ui/src/views/projects/task/components/node/fields/index.ts @@ -48,6 +48,7 @@ export { useExecutorMemory } from './use-executor-memory' export { useExecutorCores } from './use-executor-cores' export { useMainJar } from './use-main-jar' export { useResources } from './use-resources' +export { useTaskDefinition } from './use-task-definition' export { useShell } from './use-shell' export { useSpark } from './use-spark' diff --git a/dolphinscheduler-ui/src/views/projects/task/components/node/fields/use-pre-tasks.ts b/dolphinscheduler-ui/src/views/projects/task/components/node/fields/use-pre-tasks.ts index 5a472d92ae5ab0a5c21b80aeb0320a8a7d948d25..80bd285e2162b14a3b23cf71f6098e57fb6cb91b 100644 --- a/dolphinscheduler-ui/src/views/projects/task/components/node/fields/use-pre-tasks.ts +++ b/dolphinscheduler-ui/src/views/projects/task/components/node/fields/use-pre-tasks.ts @@ -15,6 +15,7 @@ * limitations under the License. */ +import { ref, watch } from 'vue' import { useI18n } from 'vue-i18n' import { useTaskNodeStore } from '@/store/project/task-node' import type { IJsonItem } from '../types' @@ -22,6 +23,14 @@ import type { IJsonItem } from '../types' export function usePreTasks(): IJsonItem { const { t } = useI18n() const taskStore = useTaskNodeStore() + const options = ref(taskStore.getPreTaskOptions) + + watch( + () => taskStore.getPreTaskOptions, + (value) => { + options.value = value + } + ) return { type: 'select', @@ -33,6 +42,6 @@ export function usePreTasks(): IJsonItem { multiple: true, filterable: true }, - options: taskStore.getPreTaskOptions + options } } diff --git a/dolphinscheduler-ui/src/views/projects/task/components/node/fields/use-process-name.ts b/dolphinscheduler-ui/src/views/projects/task/components/node/fields/use-process-name.ts index d754acbf46e327735b13e4f9635506ae7a49acec..f9cdccc2246683ba7a4d0417af4babaeaf56b710 100644 --- a/dolphinscheduler-ui/src/views/projects/task/components/node/fields/use-process-name.ts +++ b/dolphinscheduler-ui/src/views/projects/task/components/node/fields/use-process-name.ts @@ -21,6 +21,7 @@ import { querySimpleList, queryProcessDefinitionByCode } from '@/service/modules/process-definition' +import { useTaskNodeStore } from '@/store/project/task-node' import type { IJsonItem } from '../types' export function useProcessName({ @@ -28,16 +29,18 @@ export function useProcessName({ projectCode, isCreate, from, - processName + processName, + taskCode }: { model: { [field: string]: any } projectCode: number isCreate: boolean from?: number processName?: number + taskCode?: number }): IJsonItem { const { t } = useI18n() - + const taskStore = useTaskNodeStore() const options = ref([] as { label: string; value: string }[]) const loading = ref(false) @@ -55,6 +58,7 @@ export function useProcessName({ if (!processCode) return const res = await queryProcessDefinitionByCode(processCode, projectCode) model.definition = res + taskStore.updateDefinition(res, taskCode) } const onChange = (code: number) => { diff --git a/dolphinscheduler-ui/src/views/projects/task/components/node/fields/use-task-definition.ts b/dolphinscheduler-ui/src/views/projects/task/components/node/fields/use-task-definition.ts new file mode 100644 index 0000000000000000000000000000000000000000..d740e366c108d317a2fff93c3c310d368592c4b1 --- /dev/null +++ b/dolphinscheduler-ui/src/views/projects/task/components/node/fields/use-task-definition.ts @@ -0,0 +1,46 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +import { useTaskType, useProcessName } from '.' +import type { IJsonItem, ITaskData } from '../types' + +export const useTaskDefinition = ({ + projectCode, + from = 0, + readonly, + data, + model +}: { + projectCode: number + from?: number + readonly?: boolean + data?: ITaskData + model: { [field: string]: any } +}): IJsonItem[] => { + if (from === 0) return [] + return [ + useTaskType(model, readonly), + useProcessName({ + model, + projectCode, + isCreate: !data?.id, + from, + processName: data?.processName, + taskCode: data?.code + }) + ] +} diff --git a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-chunjun.ts b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-chunjun.ts index 362bd944fb0935df48dfc9eed0c8aeb1a5dbefa5..eb6dc03d7162e8d6450d9a2df2460869460ed8c9 100644 --- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-chunjun.ts +++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-chunjun.ts @@ -51,24 +51,10 @@ export function useChunjun({ timeoutNotifyStrategy: ['WARN'] } as INodeData) - let extra: IJsonItem[] = [] - if (from === 1) { - extra = [ - Fields.useTaskType(model, readonly), - Fields.useProcessName({ - model, - projectCode, - isCreate: !data?.id, - from, - processName: data?.processName - }) - ] - } - return { json: [ Fields.useName(from), - ...extra, + ...Fields.useTaskDefinition({ projectCode, from, readonly, data, model }), Fields.useRunFlag(), Fields.useDescription(), Fields.useTaskPriority(), diff --git a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-conditions.ts b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-conditions.ts index fa6124f67cefb7229c5bb266e27ec298d67c8bc4..c22b2345eb6c479c67100a6d74c1374faf32f28d 100644 --- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-conditions.ts +++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-conditions.ts @@ -50,24 +50,10 @@ export function useConditions({ timeoutNotifyStrategy: ['WARN'] } as INodeData) - let extra: IJsonItem[] = [] - if (from === 1) { - extra = [ - Fields.useTaskType(model, readonly), - Fields.useProcessName({ - model, - projectCode, - isCreate: !data?.id, - from, - processName: data?.processName - }) - ] - } - return { json: [ Fields.useName(from), - ...extra, + ...Fields.useTaskDefinition({ projectCode, from, readonly, data, model }), Fields.useRunFlag(), Fields.useDescription(), Fields.useTaskPriority(), diff --git a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-data-quality.ts b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-data-quality.ts index 91e667dd1b9e8cbd38503d8b5ce866e7914d0300..0110570dd92ed8c2e4dee0617405fe46f5eec9a3 100644 --- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-data-quality.ts +++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-data-quality.ts @@ -60,24 +60,10 @@ export function useDataQuality({ others: '--conf spark.yarn.maxAppAttempts=1' } as INodeData) - let extra: IJsonItem[] = [] - if (from === 1) { - extra = [ - Fields.useTaskType(model, readonly), - Fields.useProcessName({ - model, - projectCode, - isCreate: !data?.id, - from, - processName: data?.processName - }) - ] - } - return { json: [ Fields.useName(from), - ...extra, + ...Fields.useTaskDefinition({ projectCode, from, readonly, data, model }), Fields.useRunFlag(), Fields.useDescription(), Fields.useTaskPriority(), diff --git a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-datax.ts b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-datax.ts index 5bbc366759c8ecaa0dfbe9221577d6dfb9b44b99..21b30abd7430732724ff05b024bb2fb1aaa8000f 100644 --- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-datax.ts +++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-datax.ts @@ -54,24 +54,10 @@ export function useDataX({ timeoutNotifyStrategy: ['WARN'] } as INodeData) - let extra: IJsonItem[] = [] - if (from === 1) { - extra = [ - Fields.useTaskType(model, readonly), - Fields.useProcessName({ - model, - projectCode, - isCreate: !data?.id, - from, - processName: data?.processName - }) - ] - } - return { json: [ Fields.useName(from), - ...extra, + ...Fields.useTaskDefinition({ projectCode, from, readonly, data, model }), Fields.useRunFlag(), Fields.useDescription(), Fields.useTaskPriority(), diff --git a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-dependent.ts b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-dependent.ts index 5bb2e0e470210c05da248971ce0f40ba69abb853..2551d1076f688a5e5108c87238356e8319f57d9f 100644 --- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-dependent.ts +++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-dependent.ts @@ -51,24 +51,10 @@ export function useDependent({ ...data } as INodeData) - let extra: IJsonItem[] = [] - if (from === 1) { - extra = [ - Fields.useTaskType(model, readonly), - Fields.useProcessName({ - model, - projectCode, - isCreate: !data?.id, - from, - processName: data?.processName - }) - ] - } - return { json: [ Fields.useName(from), - ...extra, + ...Fields.useTaskDefinition({ projectCode, from, readonly, data, model }), Fields.useRunFlag(), Fields.useDescription(), Fields.useTaskPriority(), diff --git a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-dinky.ts b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-dinky.ts index 5e7a0aa0cb4154649957de2f4fc432e2ea41a020..82c2915287f9987ba609ace68ba20d43b375649b 100644 --- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-dinky.ts +++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-dinky.ts @@ -46,24 +46,10 @@ export function useDinky({ timeoutNotifyStrategy: ['WARN'] } as INodeData) - let extra: IJsonItem[] = [] - if (from === 1) { - extra = [ - Fields.useTaskType(model, readonly), - Fields.useProcessName({ - model, - projectCode, - isCreate: !data?.id, - from, - processName: data?.processName - }) - ] - } - return { json: [ Fields.useName(from), - ...extra, + ...Fields.useTaskDefinition({ projectCode, from, readonly, data, model }), Fields.useRunFlag(), Fields.useDescription(), Fields.useTaskPriority(), diff --git a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-dvc.ts b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-dvc.ts index 5838224e131e95ac93cc24fdd9efba5f3357c218..6108ca4e8e30867a1544dc980476e0900cf044a5 100644 --- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-dvc.ts +++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-dvc.ts @@ -44,27 +44,13 @@ export function useDvc({ delayTime: 0, timeout: 30, timeoutNotifyStrategy: ['WARN'], - dvcTaskType: 'Upload', + dvcTaskType: 'Upload' } as INodeData) - let extra: IJsonItem[] = [] - if (from === 1) { - extra = [ - Fields.useTaskType(model, readonly), - Fields.useProcessName({ - model, - projectCode, - isCreate: !data?.id, - from, - processName: data?.processName - }) - ] - } - return { json: [ Fields.useName(from), - ...extra, + ...Fields.useTaskDefinition({ projectCode, from, readonly, data, model }), Fields.useRunFlag(), Fields.useDescription(), Fields.useTaskPriority(), diff --git a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-emr.ts b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-emr.ts index 36dbbefa79cf508f83b8e316f6a880b04b326eb9..f6cdbaae11c4db4fd7369a68f557f81e924ba2d0 100644 --- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-emr.ts +++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-emr.ts @@ -48,24 +48,10 @@ export function useEmr({ timeoutNotifyStrategy: ['WARN'] } as INodeData) - let extra: IJsonItem[] = [] - if (from === 1) { - extra = [ - Fields.useTaskType(model, readonly), - Fields.useProcessName({ - model, - projectCode, - isCreate: !data?.id, - from, - processName: data?.processName - }) - ] - } - return { json: [ Fields.useName(from), - ...extra, + ...Fields.useTaskDefinition({ projectCode, from, readonly, data, model }), Fields.useRunFlag(), Fields.useDescription(), Fields.useTaskPriority(), diff --git a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-flink-stream.ts b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-flink-stream.ts index 33883e46fa77af927e65d20b48d531e2135f9116..d55a7b2fcbe7c6dc21c05f3e5954bd3eaba83a1b 100644 --- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-flink-stream.ts +++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-flink-stream.ts @@ -56,24 +56,10 @@ export function useFlinkStream({ timeoutNotifyStrategy: ['WARN'] }) - let extra: IJsonItem[] = [] - if (from === 1) { - extra = [ - Fields.useTaskType(model, readonly), - Fields.useProcessName({ - model, - projectCode, - isCreate: !data?.id, - from, - processName: data?.processName - }) - ] - } - return { json: [ Fields.useName(from), - ...extra, + ...Fields.useTaskDefinition({ projectCode, from, readonly, data, model }), Fields.useRunFlag(), Fields.useDescription(), Fields.useTaskPriority(), diff --git a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-flink.ts b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-flink.ts index b3c455971fad66cdeb8117a6188c4fcd517ba53d..d5671cb46df0916d51a75613a90dacb255f44e84 100644 --- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-flink.ts +++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-flink.ts @@ -56,24 +56,10 @@ export function useFlink({ timeoutNotifyStrategy: ['WARN'] }) - let extra: IJsonItem[] = [] - if (from === 1) { - extra = [ - Fields.useTaskType(model, readonly), - Fields.useProcessName({ - model, - projectCode, - isCreate: !data?.id, - from, - processName: data?.processName - }) - ] - } - return { json: [ Fields.useName(from), - ...extra, + ...Fields.useTaskDefinition({ projectCode, from, readonly, data, model }), Fields.useRunFlag(), Fields.useDescription(), Fields.useTaskPriority(), diff --git a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-http.ts b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-http.ts index 109258dfce8c2e3890a614aa9327a85ec0eeaac5..283910eab3e9afbf21abc674226b924cb6684a1d 100644 --- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-http.ts +++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-http.ts @@ -53,24 +53,10 @@ export function useHttp({ timeoutNotifyStrategy: ['WARN'] } as INodeData) - let extra: IJsonItem[] = [] - if (from === 1) { - extra = [ - Fields.useTaskType(model, readonly), - Fields.useProcessName({ - model, - projectCode, - isCreate: !data?.id, - from, - processName: data?.processName - }) - ] - } - return { json: [ Fields.useName(from), - ...extra, + ...Fields.useTaskDefinition({ projectCode, from, readonly, data, model }), Fields.useRunFlag(), Fields.useDescription(), Fields.useTaskPriority(), diff --git a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-jupyter.ts b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-jupyter.ts index 18f80f69fde0459852237a77c92bbeaa357d06c0..97f683df1ea6eabaefa4405b1b08e1d5d8d55f23 100644 --- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-jupyter.ts +++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-jupyter.ts @@ -48,24 +48,10 @@ export function useJupyter({ timeoutNotifyStrategy: ['WARN'] } as INodeData) - let extra: IJsonItem[] = [] - if (from === 1) { - extra = [ - Fields.useTaskType(model, readonly), - Fields.useProcessName({ - model, - projectCode, - isCreate: !data?.id, - from, - processName: data?.processName - }) - ] - } - return { json: [ Fields.useName(from), - ...extra, + ...Fields.useTaskDefinition({ projectCode, from, readonly, data, model }), Fields.useRunFlag(), Fields.useDescription(), Fields.useTaskPriority(), diff --git a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-k8s.ts b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-k8s.ts index c61816505e316528a24c7b06d816a0a20ba79dd9..1ae460917a3ead2984d7c1d5cf65cc6a351aef93 100644 --- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-k8s.ts +++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-k8s.ts @@ -47,24 +47,10 @@ export function useK8s({ timeoutNotifyStrategy: ['WARN'] } as INodeData) - let extra: IJsonItem[] = [] - if (from === 1) { - extra = [ - Fields.useTaskType(model, readonly), - Fields.useProcessName({ - model, - projectCode, - isCreate: !data?.id, - from, - processName: data?.processName - }) - ] - } - return { json: [ Fields.useName(), - ...extra, + ...Fields.useTaskDefinition({ projectCode, from, readonly, data, model }), Fields.useRunFlag(), Fields.useDescription(), Fields.useTaskPriority(), diff --git a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-mlflow.ts b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-mlflow.ts index 8a78f84312b273ce0e9303da13709544bfc210f6..e1957f138e22a4ca5e74ebe8312e7fdaf71c4dc9 100644 --- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-mlflow.ts +++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-mlflow.ts @@ -57,24 +57,10 @@ export function useMlflow({ timeoutNotifyStrategy: ['WARN'] } as INodeData) - let extra: IJsonItem[] = [] - if (from === 1) { - extra = [ - Fields.useTaskType(model, readonly), - Fields.useProcessName({ - model, - projectCode, - isCreate: !data?.id, - from, - processName: data?.processName - }) - ] - } - return { json: [ Fields.useName(from), - ...extra, + ...Fields.useTaskDefinition({ projectCode, from, readonly, data, model }), Fields.useRunFlag(), Fields.useDescription(), Fields.useTaskPriority(), diff --git a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-mr.ts b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-mr.ts index adf40762f7ddcdc8d6f28100005c67f8883f848f..34e4a86f46059125bd1d7aaa013718e30c7011fe 100644 --- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-mr.ts +++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-mr.ts @@ -47,24 +47,10 @@ export function useMr({ timeoutNotifyStrategy: ['WARN'] } as INodeData) - let extra: IJsonItem[] = [] - if (from === 1) { - extra = [ - Fields.useTaskType(model, readonly), - Fields.useProcessName({ - model, - projectCode, - isCreate: !data?.id, - from, - processName: data?.processName - }) - ] - } - return { json: [ Fields.useName(from), - ...extra, + ...Fields.useTaskDefinition({ projectCode, from, readonly, data, model }), Fields.useRunFlag(), Fields.useDescription(), Fields.useTaskPriority(), diff --git a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-openmldb.ts b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-openmldb.ts index 9f8d560de9fd1c6cdb1c3d317357df1c13888d7e..0e7dbaa629d725269ec348112449f28c4c3fd722 100644 --- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-openmldb.ts +++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-openmldb.ts @@ -50,24 +50,10 @@ export function useOpenmldb({ executeMode: 'offline' } as INodeData) - let extra: IJsonItem[] = [] - if (from === 1) { - extra = [ - Fields.useTaskType(model, readonly), - Fields.useProcessName({ - model, - projectCode, - isCreate: !data?.id, - from, - processName: data?.processName - }) - ] - } - return { json: [ Fields.useName(from), - ...extra, + ...Fields.useTaskDefinition({ projectCode, from, readonly, data, model }), Fields.useRunFlag(), Fields.useDescription(), Fields.useTaskPriority(), diff --git a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-pigeon.ts b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-pigeon.ts index 0d9e4713805a68c65d74ad4c961999af0b890d23..8e03244c7382414ba519cb8613df3784312a8049 100644 --- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-pigeon.ts +++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-pigeon.ts @@ -46,24 +46,10 @@ export function usePigeon({ timeoutNotifyStrategy: ['WARN'] } as INodeData) - let extra: IJsonItem[] = [] - if (from === 1) { - extra = [ - Fields.useTaskType(model, readonly), - Fields.useProcessName({ - model, - projectCode, - isCreate: !data?.id, - from, - processName: data?.processName - }) - ] - } - return { json: [ Fields.useName(from), - ...extra, + ...Fields.useTaskDefinition({ projectCode, from, readonly, data, model }), Fields.useRunFlag(), Fields.useDescription(), Fields.useTaskPriority(), diff --git a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-procedure.ts b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-procedure.ts index ecf6d2e34591c2ccf3598f37e38e8e01abd89f30..a1f5f3cfff59c799ffe270c7f5a6e4606a131aee 100644 --- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-procedure.ts +++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-procedure.ts @@ -50,24 +50,10 @@ export function useProcedure({ timeoutNotifyStrategy: ['WARN'] } as INodeData) - let extra: IJsonItem[] = [] - if (from === 1) { - extra = [ - Fields.useTaskType(model, readonly), - Fields.useProcessName({ - model, - projectCode, - isCreate: !data?.id, - from, - processName: data?.processName - }) - ] - } - return { json: [ Fields.useName(from), - ...extra, + ...Fields.useTaskDefinition({ projectCode, from, readonly, data, model }), Fields.useRunFlag(), Fields.useDescription(), Fields.useTaskPriority(), diff --git a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-python.ts b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-python.ts index 698e84dd5aed0489a8bd506d21eb3000cf23483e..7ad9ee95eccfa54a9e2c236df9c00133d0dff3a0 100644 --- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-python.ts +++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-python.ts @@ -50,24 +50,10 @@ export function usePython({ timeoutNotifyStrategy: ['WARN'] } as INodeData) - let extra: IJsonItem[] = [] - if (from === 1) { - extra = [ - Fields.useTaskType(model, readonly), - Fields.useProcessName({ - model, - projectCode, - isCreate: !data?.id, - from, - processName: data?.processName - }) - ] - } - return { json: [ Fields.useName(from), - ...extra, + ...Fields.useTaskDefinition({ projectCode, from, readonly, data, model }), Fields.useRunFlag(), Fields.useDescription(), Fields.useTaskPriority(), diff --git a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-sagemaker.ts b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-sagemaker.ts index fc3a3be0a6187e9177d8952764116d12665ea60c..f525b53a484933bf02f74bc98b52e6001f639acf 100644 --- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-sagemaker.ts +++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-sagemaker.ts @@ -43,27 +43,13 @@ export function userSagemaker({ workerGroup: 'default', delayTime: 0, timeout: 30, - timeoutNotifyStrategy: ['WARN'], + timeoutNotifyStrategy: ['WARN'] } as INodeData) - let extra: IJsonItem[] = [] - if (from === 1) { - extra = [ - Fields.useTaskType(model, readonly), - Fields.useProcessName({ - model, - projectCode, - isCreate: !data?.id, - from, - processName: data?.processName - }) - ] - } - return { json: [ Fields.useName(from), - ...extra, + ...Fields.useTaskDefinition({ projectCode, from, readonly, data, model }), Fields.useRunFlag(), Fields.useDescription(), Fields.useTaskPriority(), diff --git a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-sea-tunnel.ts b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-sea-tunnel.ts index 4efd21b99396a16e2dbec53cc6524c1e559ab37b..c570bac15b53f12797c3f02cededc5c4db797dbd 100644 --- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-sea-tunnel.ts +++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-sea-tunnel.ts @@ -77,24 +77,10 @@ export function useSeaTunnel({ '}' } as INodeData) - let extra: IJsonItem[] = [] - if (from === 1) { - extra = [ - Fields.useTaskType(model, readonly), - Fields.useProcessName({ - model, - projectCode, - isCreate: !data?.id, - from, - processName: data?.processName - }) - ] - } - return { json: [ Fields.useName(from), - ...extra, + ...Fields.useTaskDefinition({ projectCode, from, readonly, data, model }), Fields.useRunFlag(), Fields.useDescription(), Fields.useTaskPriority(), diff --git a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-shell.ts b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-shell.ts index 2caa420734a71e5c4a75e7c423bf2b2abc01202b..3808d0d633d3b49700a64bb028cb116f3a018209 100644 --- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-shell.ts +++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-shell.ts @@ -49,24 +49,10 @@ export function useShell({ rawScript: '' } as INodeData) - let extra: IJsonItem[] = [] - if (from === 1) { - extra = [ - Fields.useTaskType(model, readonly), - Fields.useProcessName({ - model, - projectCode, - isCreate: !data?.id, - from, - processName: data?.processName - }) - ] - } - return { json: [ Fields.useName(from), - ...extra, + ...Fields.useTaskDefinition({ projectCode, from, readonly, data, model }), Fields.useRunFlag(), Fields.useDescription(), Fields.useTaskPriority(), diff --git a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-spark.ts b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-spark.ts index 054709de556d20eae7cf2ac051c014f26103a14e..9d508805fc090d891462d9251755a32013e751a8 100644 --- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-spark.ts +++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-spark.ts @@ -55,24 +55,10 @@ export function useSpark({ timeoutNotifyStrategy: ['WARN'] } as INodeData) - let extra: IJsonItem[] = [] - if (from === 1) { - extra = [ - Fields.useTaskType(model, readonly), - Fields.useProcessName({ - model, - projectCode, - isCreate: !data?.id, - from, - processName: data?.processName - }) - ] - } - return { json: [ Fields.useName(from), - ...extra, + ...Fields.useTaskDefinition({ projectCode, from, readonly, data, model }), Fields.useRunFlag(), Fields.useDescription(), Fields.useTaskPriority(), diff --git a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-sql.ts b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-sql.ts index fa6a6a1e03d45bc7539bc3e65d6aad87398eb6ce..481bae1b3422070261dacbe05d37b6c428a46535 100644 --- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-sql.ts +++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-sql.ts @@ -55,24 +55,10 @@ export function useSql({ timeoutNotifyStrategy: ['WARN'] } as INodeData) - let extra: IJsonItem[] = [] - if (from === 1) { - extra = [ - Fields.useTaskType(model, readonly), - Fields.useProcessName({ - model, - projectCode, - isCreate: !data?.id, - from, - processName: data?.processName - }) - ] - } - return { json: [ Fields.useName(from), - ...extra, + ...Fields.useTaskDefinition({ projectCode, from, readonly, data, model }), Fields.useRunFlag(), Fields.useDescription(), Fields.useTaskPriority(), diff --git a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-sqoop.ts b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-sqoop.ts index 5c8cd68705d0bb50c7c21e5f7fba7f1430abf76f..cc75e37bf1dd413c9cd25f335e6e53a8bdc84f47 100644 --- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-sqoop.ts +++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-sqoop.ts @@ -69,24 +69,10 @@ export function useSqoop({ timeoutNotifyStrategy: ['WARN'] } as INodeData) - let extra: IJsonItem[] = [] - if (from === 1) { - extra = [ - Fields.useTaskType(model, readonly), - Fields.useProcessName({ - model, - projectCode, - isCreate: !data?.id, - from, - processName: data?.processName - }) - ] - } - return { json: [ Fields.useName(from), - ...extra, + ...Fields.useTaskDefinition({ projectCode, from, readonly, data, model }), Fields.useRunFlag(), Fields.useDescription(), Fields.useTaskPriority(), diff --git a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-sub-process.ts b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-sub-process.ts index ff77e3762ea77865f99124464de288c693bd5e58..77e45686d3851b3d6286f53efd3c325543459945 100644 --- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-sub-process.ts +++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-sub-process.ts @@ -49,24 +49,10 @@ export function useSubProcess({ timeoutNotifyStrategy: ['WARN'] } as INodeData) - let extra: IJsonItem[] = [] - if (from === 1) { - extra = [ - Fields.useTaskType(model, readonly), - Fields.useProcessName({ - model, - projectCode, - isCreate: !data?.id, - from, - processName: data?.processName - }) - ] - } - return { json: [ Fields.useName(from), - ...extra, + ...Fields.useTaskDefinition({ projectCode, from, readonly, data, model }), Fields.useRunFlag(), Fields.useDescription(), Fields.useTaskPriority(), diff --git a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-switch.ts b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-switch.ts index 34f054d1b154a19664c6ac316312880f282b5e77..55452c25827a941ddf5c72a84e7f2ec964532fa1 100644 --- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-switch.ts +++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-switch.ts @@ -50,24 +50,10 @@ export function useSwitch({ timeoutNotifyStrategy: ['WARN'] } as INodeData) - let extra: IJsonItem[] = [] - if (from === 1) { - extra = [ - Fields.useTaskType(model, readonly), - Fields.useProcessName({ - model, - projectCode, - isCreate: !data?.id, - from, - processName: data?.processName - }) - ] - } - return { json: [ Fields.useName(from), - ...extra, + ...Fields.useTaskDefinition({ projectCode, from, readonly, data, model }), Fields.useRunFlag(), Fields.useDescription(), Fields.useTaskPriority(), diff --git a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-zeppelin.ts b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-zeppelin.ts index d97d54ec3cda3c35fb171c2c3b7f9e20f29c4a36..823752b9a354c77c3a4175e3221c7e5aeb7d6113 100644 --- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-zeppelin.ts +++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-zeppelin.ts @@ -46,24 +46,10 @@ export function useZeppelin({ timeoutNotifyStrategy: ['WARN'] } as INodeData) - let extra: IJsonItem[] = [] - if (from === 1) { - extra = [ - Fields.useTaskType(model, readonly), - Fields.useProcessName({ - model, - projectCode, - isCreate: !data?.id, - from, - processName: data?.processName - }) - ] - } - return { json: [ Fields.useName(from), - ...extra, + ...Fields.useTaskDefinition({ projectCode, from, readonly, data, model }), Fields.useRunFlag(), Fields.useDescription(), Fields.useTaskPriority(),