Skip to content

Commit a4651e2

Browse files
jjaderbergIoannisPanagiotas
authored andcommitted
Reorder tasks
1 parent 70b117c commit a4651e2

File tree

3 files changed

+24
-24
lines changed

3 files changed

+24
-24
lines changed

algo/src/main/java/org/neo4j/gds/steiner/ShortestPathsSteinerAlgorithm.java

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -114,9 +114,7 @@ private BitSet createTerminals() {
114114
@Override
115115
public SteinerTreeResult compute() {
116116
progressTracker.beginSubTask("SteinerTree");
117-
if (applyRerouting) {
118-
progressTracker.beginSubTask("Traverse");
119-
}
117+
progressTracker.beginSubTask("Traverse");
120118
HugeLongArray parent = HugeLongArray.newArray(graph.nodeCount());
121119
HugeDoubleArray parentCost = HugeDoubleArray.newArray(graph.nodeCount());
122120
ParallelUtil.parallelForEachNode(graph.nodeCount(), concurrency, v -> {
@@ -136,11 +134,12 @@ public SteinerTreeResult compute() {
136134
processPath(path, parent, parentCost, totalCost, effectiveNodeCount);
137135
terminalsReached.increment();
138136
});
137+
progressTracker.endSubTask("Traverse");
139138

140139
if (applyRerouting) {
141-
progressTracker.endSubTask("Traverse");
142140
reroute(parent, parentCost, totalCost, effectiveNodeCount);
143141
}
142+
144143
progressTracker.endSubTask("SteinerTree");
145144
return SteinerTreeResult.of(
146145
parent,

algo/src/main/java/org/neo4j/gds/steiner/SteinerTreeAlgorithmFactory.java

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,7 @@
2626
import org.neo4j.gds.core.utils.progress.tasks.Task;
2727
import org.neo4j.gds.core.utils.progress.tasks.Tasks;
2828

29+
import java.util.ArrayList;
2930
import java.util.List;
3031
import java.util.stream.Collectors;
3132

@@ -66,14 +67,12 @@ public String taskName() {
6667
@Override
6768
public Task progressTask(Graph graph, CONFIG config) {
6869
var targetNodesSize = config.targetNodes().size();
70+
var subtasks = new ArrayList<Task>();
71+
subtasks.add(Tasks.leaf("Traverse", targetNodesSize));
6972
if (config.applyRerouting()) {
7073
long nodeCount = graph.nodeCount();
71-
return Tasks.task(taskName(), List.of(
72-
Tasks.leaf("Traverse", targetNodesSize),
73-
Tasks.leaf("Reroute", nodeCount)
74-
));
75-
} else {
76-
return Tasks.leaf(taskName(), targetNodesSize);
74+
subtasks.add(Tasks.leaf("Reroute", nodeCount));
7775
}
76+
return Tasks.task(taskName(), subtasks);
7877
}
7978
}

algo/src/test/java/org/neo4j/gds/steiner/ShortestPathsSteinerAlgorithmReroutingTest.java

Lines changed: 16 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -215,8 +215,10 @@ void shouldLogProgress() {
215215
.extracting(replaceTimings())
216216
.containsExactly(
217217
"SteinerTree :: Start",
218-
"SteinerTree 50%",
219-
"SteinerTree 100%",
218+
"SteinerTree :: Traverse :: Start",
219+
"SteinerTree :: Traverse 50%",
220+
"SteinerTree :: Traverse 100%",
221+
"SteinerTree :: Traverse :: Finished",
220222
"SteinerTree :: Finished"
221223
);
222224
}
@@ -252,18 +254,18 @@ void shouldLogProgressWithRerouting() {
252254
.extracting(replaceTimings())
253255
.containsExactly(
254256
"SteinerTree :: Start",
255-
"SteinerTree :: Main :: Start",
256-
"SteinerTree :: Main 50%",
257-
"SteinerTree :: Main 100%",
258-
"SteinerTree :: Main :: Finished",
259-
"SteinerTree :: Rerouting :: Start",
260-
"SteinerTree :: Rerouting 16%",
261-
"SteinerTree :: Rerouting 33%",
262-
"SteinerTree :: Rerouting 50%",
263-
"SteinerTree :: Rerouting 66%",
264-
"SteinerTree :: Rerouting 83%",
265-
"SteinerTree :: Rerouting 100%",
266-
"SteinerTree :: Rerouting :: Finished",
257+
"SteinerTree :: Traverse :: Start",
258+
"SteinerTree :: Traverse 50%",
259+
"SteinerTree :: Traverse 100%",
260+
"SteinerTree :: Traverse :: Finished",
261+
"SteinerTree :: Reroute :: Start",
262+
"SteinerTree :: Reroute 16%",
263+
"SteinerTree :: Reroute 33%",
264+
"SteinerTree :: Reroute 50%",
265+
"SteinerTree :: Reroute 66%",
266+
"SteinerTree :: Reroute 83%",
267+
"SteinerTree :: Reroute 100%",
268+
"SteinerTree :: Reroute :: Finished",
267269
"SteinerTree :: Finished"
268270
);
269271
}

0 commit comments

Comments
 (0)