[Improvement] Dependent tasks support dependent policies

dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/task/DependentTaskProcessor.java

@@ -44,12 +44,12 @@ import com.google.auto.service.AutoService;
 @AutoService(ITaskProcessor.class)
 public class DependentTaskProcessor extends BaseTaskProcessor {
 
-    private DependentParameters dependentParameters;
+    protected DependentParameters dependentParameters;
 
     /**
      * dependent task list
      */
-    private List<DependentExecute> dependentTaskList = new ArrayList<>();
+    protected List<DependentExecute> dependentTaskList = new ArrayList<>();
 
     /**
      * depend item result map
@@ -60,7 +60,7 @@ public class DependentTaskProcessor extends BaseTaskProcessor {
     /**
      * dependent date
      */
-    private Date dependentDate;
+    protected Date dependentDate;
 
     DependResult result;
 

dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/utils/DependentExecute.java

@@ -137,7 +137,7 @@ public class DependentExecute {
      *
      * @return
      */
-    private DependResult dependResultByProcessInstance(ProcessInstance processInstance) {
+    protected DependResult dependResultByProcessInstance(ProcessInstance processInstance) {
         if (!processInstance.getState().typeIsFinished()) {
             return DependResult.WAITING;
         }
@@ -154,7 +154,7 @@ public class DependentExecute {
      * @param processInstance
      * @return
      */
-    private DependResult getDependTaskResult(long taskCode, ProcessInstance processInstance) {
+    protected DependResult getDependTaskResult(long taskCode, ProcessInstance processInstance) {
         DependResult result;
         TaskInstance taskInstance = null;
         List<TaskInstance> taskInstanceList = processService.findValidTaskListByProcessId(processInstance.getId());
@@ -190,7 +190,7 @@ public class DependentExecute {
      * @param dateInterval   date interval
      * @return ProcessInstance
      */
-    private ProcessInstance findLastProcessInterval(Long definitionCode, DateInterval dateInterval) {
+    protected ProcessInstance findLastProcessInterval(Long definitionCode, DateInterval dateInterval) {
 
         ProcessInstance lastSchedulerProcess =
                 processService.findLastSchedulerProcessInterval(definitionCode, dateInterval);