提交 e32ddc12 编写于 作者: 薛            之            谦's avatar 薛 之 谦

[Improvement] Dependent tasks support dependent policies

上级 0345389c
......@@ -33,8 +33,10 @@ import org.apache.dolphinscheduler.plugin.task.api.parameters.SwitchParameters;
import java.io.Serializable;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;
import static org.apache.dolphinscheduler.common.Constants.NULL;
import static org.apache.dolphinscheduler.common.Constants.SEC_2_MINUTES_TIME_UNIT;
import static org.apache.dolphinscheduler.plugin.task.api.TaskConstants.TASK_TYPE_BLOCKING;
import static org.apache.dolphinscheduler.plugin.task.api.TaskConstants.TASK_TYPE_CONDITIONS;
......@@ -477,7 +479,8 @@ public class TaskInstance implements Serializable {
Map<String, Object> taskParamsMap = JSONUtils.parseObject(this.getTaskParams(), new TypeReference<Map<String, Object>>() {
});
this.dependency = JSONUtils.parseObject((String) taskParamsMap.get(Constants.DEPENDENCE), DependentParameters.class);
this.dependency.setOtherParams((Map<String, Object>) taskParamsMap.get(Constants.OTHER_PARAMS));
Map<String, Object> otherMap = taskParamsMap.get(Constants.OTHER_PARAMS)==null?new HashMap<>(): (Map<String, Object>) taskParamsMap.get(Constants.OTHER_PARAMS);
this.dependency.setOtherParams(otherMap);
}
return this.dependency;
}
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册