Skip to content

Commit 0327754

Browse files
authored
Merge pull request #8691 from Mats-SX/26-remoteprojprogress
2.6 - Fix remote projection progress logging
2 parents bde4aa8 + 6857db3 commit 0327754

File tree

2 files changed

+15
-0
lines changed

2 files changed

+15
-0
lines changed

core-test-utils/src/main/java/org/neo4j/gds/assertj/Extractors.java

+11
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,17 @@ public final class Extractors {
3131

3232
private Extractors() {}
3333

34+
public static ThrowingExtractor<String, String, RuntimeException> removingServerAddress() {
35+
return Extractors::removingServerAddress;
36+
}
37+
38+
private static String removingServerAddress(String message) {
39+
if (message.contains("localhost:")) {
40+
return removingServerAddress(message.replaceFirst("localhost:\\d+", "<address>"));
41+
}
42+
return message;
43+
}
44+
3445
public static ThrowingExtractor<String, String, RuntimeException> removingThreadId() {
3546
return Extractors::removeThreadId;
3647
}

core/src/main/java/org/neo4j/gds/api/DatabaseInfo.java

+4
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,10 @@ static DatabaseInfo of(DatabaseId databaseId, DatabaseLocation databaseLocation)
3131
return ImmutableDatabaseInfo.of(databaseId, databaseLocation, Optional.empty());
3232
}
3333

34+
static DatabaseInfo of(DatabaseId databaseId, DatabaseLocation databaseLocation, DatabaseId remoteDatabaseId) {
35+
return ImmutableDatabaseInfo.of(databaseId, databaseLocation, remoteDatabaseId);
36+
}
37+
3438
DatabaseId databaseId();
3539

3640
DatabaseLocation databaseLocation();

0 commit comments

Comments
 (0)