diff --git a/core/src/main/java/org/neo4j/gds/core/loading/GraphStoreCatalog.java b/core/src/main/java/org/neo4j/gds/core/loading/GraphStoreCatalog.java index 5dce7fa434..754a111d0a 100644 --- a/core/src/main/java/org/neo4j/gds/core/loading/GraphStoreCatalog.java +++ b/core/src/main/java/org/neo4j/gds/core/loading/GraphStoreCatalog.java @@ -186,7 +186,7 @@ private static void set(GraphProjectConfig config, GraphStore graphStore, boolea listeners.forEach(listener -> { try { - listener.onProject(config.username(), config.graphName()); + listener.onProject(config.username(), graphStore.databaseId().databaseName(), config.graphName()); } catch (Exception e) { log.ifPresent(l -> l.warn(String.format( Locale.US, diff --git a/core/src/main/java/org/neo4j/gds/core/loading/GraphStoreCatalogListener.java b/core/src/main/java/org/neo4j/gds/core/loading/GraphStoreCatalogListener.java index da3e3025e2..3b28be35ab 100644 --- a/core/src/main/java/org/neo4j/gds/core/loading/GraphStoreCatalogListener.java +++ b/core/src/main/java/org/neo4j/gds/core/loading/GraphStoreCatalogListener.java @@ -21,5 +21,5 @@ public interface GraphStoreCatalogListener { - void onProject(String user, String graphName); + void onProject(String user, String database, String graphName); } diff --git a/core/src/test/java/org/neo4j/gds/core/loading/GraphStoreCatalogTest.java b/core/src/test/java/org/neo4j/gds/core/loading/GraphStoreCatalogTest.java index 8b10e2fd6b..18e9e7ad55 100644 --- a/core/src/test/java/org/neo4j/gds/core/loading/GraphStoreCatalogTest.java +++ b/core/src/test/java/org/neo4j/gds/core/loading/GraphStoreCatalogTest.java @@ -421,7 +421,7 @@ void callListeners() { var listener = new GraphStoreCatalogListener() { @Override - public void onProject(String user, String graphName) { + public void onProject(String user, String database, String graphName) { listenerCalls.increment(); } };