Skip to content

Commit f1ca93a

Browse files
committed
Improve progress tracking for triplet import
1 parent 9a53a98 commit f1ca93a

File tree

2 files changed

+5
-1
lines changed
  • progress-tracking/src/main/java/org/neo4j/gds/core/utils/progress/tasks
  • triplet-graph-builder/src/main/java/org/neo4j/gds/projection

2 files changed

+5
-1
lines changed

progress-tracking/src/main/java/org/neo4j/gds/core/utils/progress/tasks/Progress.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,10 @@ public interface Progress {
3030

3131
@Value.Lazy
3232
default double relativeProgress() {
33+
if (volume() == Task.UNKNOWN_VOLUME) {
34+
return Task.UNKNOWN_VOLUME;
35+
}
36+
3337
// progress can be larger if the volume was estimated too low (such as for cypher projections)
3438
return progress() >= volume()
3539
? 1.0D

triplet-graph-builder/src/main/java/org/neo4j/gds/projection/GraphImporter.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,7 @@ public static Task graphImporterTask(int taskVolume) {
8282
return Tasks.task(
8383
"Graph aggregation",
8484
Tasks.leaf("Update aggregation", taskVolume),
85-
Tasks.task("Build graph store", Tasks.leaf("Nodes"), Tasks.leaf("Relationships"))
85+
Tasks.task("Build graph store", Tasks.leaf("Nodes", 1), Tasks.leaf("Relationships", 1))
8686
);
8787
}
8888

0 commit comments

Comments
 (0)