Fix default value for concurrency in remote projection

the java code expects the input to be not present or a valid number. NULL is not accepted

Author: FlorentinD

graphdatascience/procedure_surface/arrow/catalog_arrow_endpoints.py

@@ -114,11 +114,12 @@ def project(
 
         job_id = job_id if job_id is not None else str(uuid4())
 
-        params = {
-            "concurrency": concurrency,
+        params: dict[str, Any] = {
             "undirected_relationship_types": undirected_relationship_types,
             "inverse_indexed_relationship_types": inverse_indexed_relationship_types,
         }
+        if concurrency is not None:
+            params["concurrency"] = concurrency
 
         project_params = self._project_protocol.project_params(graph_name, query, job_id, params, arrow_config)
 

graphdatascience/query_runner/protocol/project_protocols.py

@@ -51,7 +51,7 @@ def project_params(
         return CallParameters(
             graph_name=graph_name,
             query=query,
-            concurrency=params["concurrency"],
+            concurrency=params.get("concurrency", 4),
             undirected_relationship_types=params["undirected_relationship_types"],
             inverse_indexed_relationship_types=params["inverse_indexed_relationship_types"],
             arrow_configuration=arrow_config,
@@ -77,15 +77,17 @@ class ProjectProtocolV2(ProjectProtocol):
     def project_params(
         self, graph_name: str, query: str, job_id: str, params: dict[str, Any], arrow_config: dict[str, Any]
     ) -> CallParameters:
+        config = {
+            "undirectedRelationshipTypes": params["undirected_relationship_types"],
+            "inverseIndexedRelationshipTypes": params["inverse_indexed_relationship_types"],
+        }
+        if "concurrency" in params:
+            config["concurrency"] = params["concurrency"]
         return CallParameters(
             graph_name=graph_name,
             query=query,
             arrow_configuration=arrow_config,
-            configuration={
-                "concurrency": params["concurrency"],
-                "undirectedRelationshipTypes": params["undirected_relationship_types"],
-                "inverseIndexedRelationshipTypes": params["inverse_indexed_relationship_types"],
-            },
+            configuration=config,
         )
 
     def run_projection(
@@ -108,16 +110,19 @@ class ProjectProtocolV3(ProjectProtocol):
     def project_params(
         self, graph_name: str, query: str, job_id: str, params: dict[str, Any], arrow_config: dict[str, Any]
     ) -> CallParameters:
+        config = {
+            "undirectedRelationshipTypes": params["undirected_relationship_types"],
+            "inverseIndexedRelationshipTypes": params["inverse_indexed_relationship_types"],
+        }
+        if "concurrency" in params:
+            config["concurrency"] = params["concurrency"]
+
         return CallParameters(
             graph_name=graph_name,
             query=query,
             job_id=job_id,
             arrow_configuration=arrow_config,
-            configuration={
-                "concurrency": params["concurrency"],
-                "undirectedRelationshipTypes": params["undirected_relationship_types"],
-                "inverseIndexedRelationshipTypes": params["inverse_indexed_relationship_types"],
-            },
+            configuration=config,
         )
 
     def run_projection(