|
|
@ -22,7 +22,9 @@ import type { |
|
|
|
ITaskParams, |
|
|
|
ITaskParams, |
|
|
|
ISqoopTargetParams, |
|
|
|
ISqoopTargetParams, |
|
|
|
ISqoopSourceParams, |
|
|
|
ISqoopSourceParams, |
|
|
|
ILocalParam |
|
|
|
ILocalParam, |
|
|
|
|
|
|
|
IDependTask, |
|
|
|
|
|
|
|
RelationType |
|
|
|
} from './types' |
|
|
|
} from './types' |
|
|
|
|
|
|
|
|
|
|
|
export function formatParams(data: INodeData): { |
|
|
|
export function formatParams(data: INodeData): { |
|
|
@ -625,9 +627,11 @@ export function formatModel(data: ITaskData) { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
if (data.taskParams?.dependence) { |
|
|
|
if (data.taskParams?.dependence) { |
|
|
|
params.dependTaskList = data.taskParams?.dependence.dependTaskList || [] |
|
|
|
const dependence: { relation?: RelationType, dependTaskList?: IDependTask[] } = JSON.parse(JSON.stringify(data.taskParams.dependence)) |
|
|
|
params.relation = data.taskParams?.dependence.relation |
|
|
|
params.dependTaskList = dependence.dependTaskList || [] |
|
|
|
|
|
|
|
params.relation = dependence.relation |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
if (data.taskParams?.ruleInputParameter) { |
|
|
|
if (data.taskParams?.ruleInputParameter) { |
|
|
|
params.check_type = data.taskParams.ruleInputParameter.check_type |
|
|
|
params.check_type = data.taskParams.ruleInputParameter.check_type |
|
|
|
params.comparison_execute_sql = |
|
|
|
params.comparison_execute_sql = |
|
|
|