Commit c95e40fd by gdj

修复条件任务不执行bug。

parent 05c30570
......@@ -558,7 +558,8 @@ public class FlightTaskServiceImpl extends AbstractWaylineService implements IFl
log.info("ready task list:{}", Arrays.toString(flightIds.toArray()) );
// Check conditional task blocking status.
String blockedId = waylineRedisService.getBlockedWaylineJobId(response.getGateway());
if (!StringUtils.hasText(blockedId)) {
// fix: 修复条件任务不执行bug
if (StringUtils.hasText(blockedId)) {
return null;
}
......
......@@ -70,7 +70,7 @@ public class WaylineRedisServiceImpl implements IWaylineRedisService {
throw new RuntimeException("Job id can't be null.");
}
RedisOpsUtils.setWithExpire(RedisConst.WAYLINE_JOB_CONDITION_PREFIX + waylineJob.getJobId(), waylineJob,
(Duration.between(waylineJob.getEndTime(), LocalDateTime.now()).getSeconds()));
Math.abs(Duration.between(waylineJob.getEndTime(), LocalDateTime.now()).getSeconds()));
}
@Override
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment