Use algo concurrency value when loading graphs implicitly

(cherry picked from commit 174b90a6bb234b8693f94e0e9bd9b3a0e63a5a33)

Author: soerenreichardt

core/src/main/java/org/neo4j/graphalgo/config/AlgoBaseConfig.java

@@ -39,6 +39,7 @@ public interface AlgoBaseConfig extends BaseConfig {
     List<String> ALL_NODE_LABELS = Collections.singletonList(ALL_NODES.name());
     List<NodeLabel> ALL_NODE_LABEL_IDENTIFIERS = Collections.singletonList(ALL_NODES);
     List<RelationshipType> ALL_RELATIONSHIP_TYPE_IDENTIFIERS = Collections.singletonList(ALL_RELATIONSHIPS);
+    String CONCURRENCY_KEY = "concurrency";
 
     @Value.Default
     default int concurrency() {

core/src/main/java/org/neo4j/graphalgo/config/GraphCreateConfig.java

@@ -37,6 +37,7 @@
 public interface GraphCreateConfig extends BaseConfig {
 
     String IMPLICIT_GRAPH_NAME = "";
+    String READ_CONCURRENCY_KEY = "readConcurrency";
 
     @Configuration.Parameter
     String graphName();

proc/common/src/main/java/org/neo4j/graphalgo/AlgoBaseProc.java

@@ -63,7 +63,10 @@
 import java.util.stream.Stream;
 
 import static org.neo4j.graphalgo.NodeLabel.ALL_NODES;
+import static org.neo4j.graphalgo.config.AlgoBaseConfig.CONCURRENCY_KEY;
+import static org.neo4j.graphalgo.config.AlgoBaseConfig.DEFAULT_CONCURRENCY;
 import static org.neo4j.graphalgo.config.BaseConfig.SUDO_KEY;
+import static org.neo4j.graphalgo.config.GraphCreateConfig.READ_CONCURRENCY_KEY;
 
 public abstract class AlgoBaseProc<
     ALGO extends Algorithm<ALGO, ALGO_RESULT>,
@@ -86,8 +89,10 @@ protected abstract CONFIG newConfig(
     public final CONFIG newConfig(Optional<String> graphName, CypherMapWrapper config) {
         Optional<GraphCreateConfig> maybeImplicitCreate = Optional.empty();
         Collection<String> allowedKeys = new HashSet<>();
+        // implicit loading
         if (!graphName.isPresent()) {
-            // we should do implicit loading
+            // inherit concurrency from AlgoBaseConfig
+            config = config.withNumber(READ_CONCURRENCY_KEY, config.getInt(CONCURRENCY_KEY, DEFAULT_CONCURRENCY));
             GraphCreateConfig createConfig = GraphCreateConfig.createImplicit(getUsername(), config);
             maybeImplicitCreate = Optional.of(createConfig);
             allowedKeys.addAll(createConfig.configKeys());

proc/test/src/main/java/org/neo4j/graphalgo/AlgoBaseProcTest.java

@@ -159,9 +159,11 @@ default void testImplicitGraphCreateFromStoreConfig() {
 
     @Test
     default void testImplicitGraphCreateFromCypherConfig() {
+        long concurrency = 2;
         Map<String, Object> tempConfig = MapUtil.map(
             NODE_QUERY_KEY, ALL_NODES_QUERY,
-            RELATIONSHIP_QUERY_KEY, ALL_RELATIONSHIPS_QUERY
+            RELATIONSHIP_QUERY_KEY, ALL_RELATIONSHIPS_QUERY,
+            "concurrency", concurrency
         );
         CypherMapWrapper wrapper = createMinimalConfig(CypherMapWrapper.create(tempConfig));
 
@@ -182,6 +184,7 @@ default void testImplicitGraphCreateFromCypherConfig() {
             assertEquals(ALL_RELATIONSHIPS_QUERY, actualConfig.relationshipQuery());
             assertEquals(IMPLICIT_GRAPH_NAME, actualConfig.graphName());
             assertEquals(TEST_USERNAME, actualConfig.username());
+            assertEquals(concurrency, actualConfig.readConcurrency());
         });
     }