Loading dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/ProcessDao.java +3 −0 Original line number Diff line number Diff line Loading @@ -972,6 +972,9 @@ public class ProcessDao { public Boolean submitTaskToQueue(TaskInstance taskInstance) { try{ if(taskInstance.isSubProcess()){ return true; } if(taskInstance.getState().typeIsFinished()){ logger.info(String.format("submit to task queue, but task [%s] state [%s] is already finished. ", taskInstance.getName(), taskInstance.getState().toString())); return true; Loading Loading
dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/ProcessDao.java +3 −0 Original line number Diff line number Diff line Loading @@ -972,6 +972,9 @@ public class ProcessDao { public Boolean submitTaskToQueue(TaskInstance taskInstance) { try{ if(taskInstance.isSubProcess()){ return true; } if(taskInstance.getState().typeIsFinished()){ logger.info(String.format("submit to task queue, but task [%s] state [%s] is already finished. ", taskInstance.getName(), taskInstance.getState().toString())); return true; Loading