|
|
@ -90,7 +90,6 @@ public class ConditionTaskProcessor extends BaseTaskProcessor { |
|
|
|
Thread.currentThread().setName(threadLoggerInfoName); |
|
|
|
Thread.currentThread().setName(threadLoggerInfoName); |
|
|
|
initTaskParameters(); |
|
|
|
initTaskParameters(); |
|
|
|
logger.info("dependent task start"); |
|
|
|
logger.info("dependent task start"); |
|
|
|
endTask(); |
|
|
|
|
|
|
|
return true; |
|
|
|
return true; |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
@ -103,6 +102,7 @@ public class ConditionTaskProcessor extends BaseTaskProcessor { |
|
|
|
public void run() { |
|
|
|
public void run() { |
|
|
|
if (conditionResult.equals(DependResult.WAITING)) { |
|
|
|
if (conditionResult.equals(DependResult.WAITING)) { |
|
|
|
setConditionResult(); |
|
|
|
setConditionResult(); |
|
|
|
|
|
|
|
endTask(); |
|
|
|
} else { |
|
|
|
} else { |
|
|
|
endTask(); |
|
|
|
endTask(); |
|
|
|
} |
|
|
|
} |
|
|
|