File tree Expand file tree Collapse file tree 1 file changed +10
-2
lines changed
cypher-aggregation/src/main/java/org/neo4j/gds/projection Expand file tree Collapse file tree 1 file changed +10
-2
lines changed Original file line number Diff line number Diff line change @@ -109,10 +109,18 @@ public CompatUserAggregator create(Context ctx) throws ProcedureException {
109109 var metricsFacade = Neo4jProxy .lookupComponentProvider (ctx , MetricsFacade .class , true );
110110 var username = Neo4jProxy .lookupComponentProvider (ctx , Username .class , true );
111111 var transaction = Neo4jProxy .lookupComponentProvider (ctx , Transaction .class , true );
112- var ktxs = GraphDatabaseApiProxy .resolveDependency (databaseService , KernelTransactions .class );
113- var queryProvider = ExecutingQueryProvider .fromTransaction (ktxs , transaction );
114112
115113 var runsOnCompositeDatabase = Neo4jProxy .isCompositeDatabase (databaseService );
114+
115+ ExecutingQueryProvider queryProvider ;
116+ if (runsOnCompositeDatabase ) {
117+ queryProvider = ExecutingQueryProvider .empty ();
118+ } else {
119+ assert GraphDatabaseApiProxy .containsDependency (databaseService , KernelTransactions .class );
120+ var ktxs = GraphDatabaseApiProxy .resolveDependency (databaseService , KernelTransactions .class );
121+ queryProvider = ExecutingQueryProvider .fromTransaction (ktxs , transaction );
122+ }
123+
116124 var writeMode = runsOnCompositeDatabase
117125 ? WriteMode .NONE
118126 : WriteMode .LOCAL ;
You can’t perform that action at this time.
0 commit comments