Browse Source

update some method to protected (#9169)

3.0.0/version-upgrade
gaojun2048 2 years ago committed by GitHub
parent
commit
9996f7a4fa
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
  1. 6
      dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessService.java

6
dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessService.java

@ -302,7 +302,7 @@ public class ProcessService {
return processInstance; return processInstance;
} }
private void saveSerialProcess(ProcessInstance processInstance, ProcessDefinition processDefinition) { protected void saveSerialProcess(ProcessInstance processInstance, ProcessDefinition processDefinition) {
processInstance.setState(ExecutionStatus.SERIAL_WAIT); processInstance.setState(ExecutionStatus.SERIAL_WAIT);
saveProcessInstance(processInstance); saveProcessInstance(processInstance);
//serial wait //serial wait
@ -852,7 +852,7 @@ public class ProcessService {
* @param host host * @param host host
* @return process instance * @return process instance
*/ */
private ProcessInstance constructProcessInstance(Command command, String host) { protected ProcessInstance constructProcessInstance(Command command, String host) {
ProcessInstance processInstance; ProcessInstance processInstance;
ProcessDefinition processDefinition; ProcessDefinition processDefinition;
CommandType commandType = command.getCommandType(); CommandType commandType = command.getCommandType();
@ -2908,7 +2908,7 @@ public class ProcessService {
return this.processInstanceMapper.loadNextProcess4Serial(code, state); return this.processInstanceMapper.loadNextProcess4Serial(code, state);
} }
private void deleteCommandWithCheck(int commandId) { protected void deleteCommandWithCheck(int commandId) {
int delete = this.commandMapper.deleteById(commandId); int delete = this.commandMapper.deleteById(commandId);
if (delete != 1) { if (delete != 1) {
throw new ServiceException("delete command fail, id:" + commandId); throw new ServiceException("delete command fail, id:" + commandId);

Loading…
Cancel
Save