Skip to content

Commit

Permalink
Add spotless
Browse files Browse the repository at this point in the history
  • Loading branch information
terrymanu committed Oct 13, 2023
1 parent ff6ecef commit 4c7619c
Showing 1 changed file with 3 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -65,14 +65,13 @@ public RunningService(final CoordinatorRegistryCenter regCenter) {
*/
public void start() {
clear();
List<String> jobKeys = regCenter.getChildrenKeys(RunningNode.ROOT);
for (String each : jobKeys) {
for (String each : regCenter.getChildrenKeys(RunningNode.ROOT)) {
if (!configurationService.load(each).isPresent()) {
remove(each);
continue;
}
RUNNING_TASKS.put(each, Sets.newCopyOnWriteArraySet(regCenter.getChildrenKeys(RunningNode.getRunningJobNodePath(each)).stream().map(
input -> TaskContext.from(regCenter.get(RunningNode.getRunningTaskNodePath(MetaInfo.from(input).toString())))).collect(Collectors.toList())));
RUNNING_TASKS.put(each, Sets.newCopyOnWriteArraySet(regCenter.getChildrenKeys(RunningNode.getRunningJobNodePath(each)).stream()
.map(input -> TaskContext.from(regCenter.get(RunningNode.getRunningTaskNodePath(MetaInfo.from(input).toString())))).collect(Collectors.toList())));
}
}

Expand Down

0 comments on commit 4c7619c

Please sign in to comment.