Skip to content

Commit 37f5cb4

Browse files
authored
Merge pull request #9884 from DarthMax/av2_support_triplet_import
[AV2] Implement triplet import
2 parents ea1a229 + 233b4ba commit 37f5cb4

File tree

3 files changed

+6
-2
lines changed

3 files changed

+6
-2
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

progress-tracking/src/test/java/org/neo4j/gds/core/utils/progress/tasks/ProgressTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@ class ProgressTest {
2727

2828
@Test
2929
void relativeProgress() {
30-
assertThat(ImmutableProgress.of(40, Task.UNKNOWN_VOLUME).relativeProgress()).isEqualTo(1.0);
30+
assertThat(ImmutableProgress.of(40, Task.UNKNOWN_VOLUME).relativeProgress()).isEqualTo(-1.0);
3131
assertThat(ImmutableProgress.of(40, 40).relativeProgress()).isEqualTo(1.0);
3232
assertThat(ImmutableProgress.of(44, 40).relativeProgress()).isEqualTo(1.0);
3333

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)