Dont expose write_to_result_store param

Author: FlorentinD

graphdatascience/procedure_surface/api/community/clique_counting_endpoints.py

@@ -150,7 +150,6 @@ def write(
         sudo: Optional[bool] = False,
         username: Optional[str] = None,
         write_concurrency: Optional[int] = None,
-        write_to_result_store: Optional[bool] = False,
     ) -> CliqueCountingWriteResult:
         """
         Executes the clique counting algorithm and writes the results back to the database.
@@ -177,8 +176,6 @@ def write(
             The username to attribute the procedure run to
         write_concurrency : Optional[int], default=None
             The number of concurrent threads for write operations
-        write_to_result_store : Optional[bool], default=False
-            Whether to write to the result store
 
         Returns
         -------
@@ -220,7 +217,7 @@ def estimate(
 class CliqueCountingMutateResult(BaseResult):
     compute_millis: int
     configuration: dict[str, Any]
-    global_count: List[Any]
+    global_count: List[int]
     mutate_millis: int
     node_properties_written: int
     pre_processing_millis: int
@@ -229,14 +226,14 @@ class CliqueCountingMutateResult(BaseResult):
 class CliqueCountingStatsResult(BaseResult):
     compute_millis: int
     configuration: dict[str, Any]
-    global_count: List[Any]
+    global_count: List[int]
     pre_processing_millis: int
 
 
 class CliqueCountingWriteResult(BaseResult):
     compute_millis: int
     configuration: dict[str, Any]
-    global_count: List[Any]
+    global_count: List[int]
     node_properties_written: int
     pre_processing_millis: int
     write_millis: int

graphdatascience/procedure_surface/api/community/kmeans_endpoints.py

@@ -64,7 +64,7 @@ def mutate(
         node_labels : Optional[List[str]], default=None
             The node labels used to select nodes for this algorithm run
         number_of_restarts : Optional[int], default=1
-            The number of times the algorithm should be restarted
+            The number of times the algorithm should be restarted with different initial centers
         random_seed : Optional[int], default=None
             Random seed for reproducible results
         relationship_types : Optional[List[str]], default=None
@@ -133,7 +133,7 @@ def stats(
         node_labels : Optional[List[str]], default=None
             The node labels used to select nodes for this algorithm run
         number_of_restarts : Optional[int], default=1
-            The number of times the algorithm should be restarted
+            The number of times the algorithm should be restarted with different initial centers
         random_seed : Optional[int], default=None
             Random seed for reproducible results
         relationship_types : Optional[List[str]], default=None
@@ -202,7 +202,7 @@ def stream(
         node_labels : Optional[List[str]], default=None
             The node labels used to select nodes for this algorithm run
         number_of_restarts : Optional[int], default=1
-            The number of times the algorithm should be restarted
+            The number of times the algorithm should be restarted with different initial centers
         random_seed : Optional[int], default=None
             Random seed for reproducible results
         relationship_types : Optional[List[str]], default=None
@@ -244,7 +244,6 @@ def write(
         sudo: Optional[bool] = False,
         username: Optional[str] = None,
         write_concurrency: Optional[int] = None,
-        write_to_result_store: Optional[bool] = False,
     ) -> KMeansWriteResult:
         """
         Executes the K-Means algorithm and writes the results back to the database.
@@ -276,7 +275,7 @@ def write(
         node_labels : Optional[List[str]], default=None
             The node labels used to select nodes for this algorithm run
         number_of_restarts : Optional[int], default=1
-            The number of times the algorithm should be restarted
+            The number of times the algorithm should be restarted with different initial centers
         random_seed : Optional[int], default=None
             Random seed for reproducible results
         relationship_types : Optional[List[str]], default=None
@@ -289,8 +288,6 @@ def write(
             The username to attribute the procedure run to
         write_concurrency : Optional[int], default=None
             The number of concurrent threads for write operations
-        write_to_result_store : Optional[bool], default=False
-            Whether to write to the result store
 
         Returns
         -------
@@ -341,7 +338,7 @@ def estimate(
         node_labels : Optional[List[str]], default=None
             The node labels used to select nodes for this algorithm run
         number_of_restarts : Optional[int], default=1
-            The number of times the algorithm should be restarted
+            The number of times the algorithm should be restarted with different initial centers
         random_seed : Optional[int], default=None
             Random seed for reproducible results
         relationship_types : Optional[List[str]], default=None

graphdatascience/procedure_surface/api/community/labelpropagation_endpoints.py

@@ -208,7 +208,6 @@ def write(
         sudo: Optional[bool] = False,
         username: Optional[str] = None,
         write_concurrency: Optional[int] = None,
-        write_to_result_store: Optional[bool] = False,
     ) -> LabelPropagationWriteResult:
         """
         Executes the Label Propagation algorithm and writes the results back to the database.
@@ -247,8 +246,6 @@ def write(
             The username to attribute the procedure run to
         write_concurrency : Optional[int], default=None
             The number of concurrent threads for write operations
-        write_to_result_store : Optional[bool], default=False
-            Whether to write to the result store
 
         Returns
         -------

graphdatascience/procedure_surface/api/community/leiden_endpoints.py

@@ -245,7 +245,6 @@ def write(
         tolerance: Optional[float] = 1e-4,
         username: Optional[str] = None,
         write_concurrency: Optional[int] = None,
-        write_to_result_store: Optional[bool] = False,
     ) -> "LeidenWriteResult":
         """
         Executes the Leiden community detection algorithm and writes the results back to the database.
@@ -292,9 +291,7 @@ def write(
             The username to attribute the procedure run to
         write_concurrency : Optional[int], default=None
             The number of concurrent threads for writing
-        write_to_result_store : Optional[bool], default=False
-            Whether to write to result store
-
+            
         Returns
         -------
         LeidenWriteResult

graphdatascience/procedure_surface/arrow/clique_counting_arrow_endpoints.py

@@ -120,7 +120,6 @@ def write(
         sudo: Optional[bool] = False,
         username: Optional[str] = None,
         write_concurrency: Optional[Any] = None,
-        write_to_result_store: Optional[bool] = False,
     ) -> CliqueCountingWriteResult:
         config = self._node_property_endpoints.create_base_config(
             G,
@@ -131,7 +130,6 @@ def write(
             relationship_types=relationship_types,
             sudo=sudo,
             username=username,
-            write_to_result_store=write_to_result_store,
         )
 
         result = self._node_property_endpoints.run_job_and_write(

graphdatascience/procedure_surface/arrow/kmeans_arrow_endpoints.py

@@ -183,7 +183,6 @@ def write(
         sudo: Optional[bool] = False,
         username: Optional[str] = None,
         write_concurrency: Optional[Any] = None,
-        write_to_result_store: Optional[bool] = False,
     ) -> KMeansWriteResult:
         config = self._node_property_endpoints.create_base_config(
             G,
@@ -203,7 +202,6 @@ def write(
             seed_centroids=seed_centroids,
             sudo=sudo,
             username=username,
-            write_to_result_store=write_to_result_store,
         )
 
         result = self._node_property_endpoints.run_job_and_write(

graphdatascience/procedure_surface/arrow/labelpropagation_arrow_endpoints.py

@@ -162,7 +162,6 @@ def write(
         sudo: Optional[bool] = False,
         username: Optional[str] = None,
         write_concurrency: Optional[int] = None,
-        write_to_result_store: Optional[bool] = False,
     ) -> LabelPropagationWriteResult:
         config = self._node_property_endpoints.create_base_config(
             G,
@@ -179,7 +178,6 @@ def write(
             seed_property=seed_property,
             sudo=sudo,
             username=username,
-            write_to_result_store=write_to_result_store,
         )
 
         result = self._node_property_endpoints.run_job_and_write(

graphdatascience/procedure_surface/arrow/leiden_arrow_endpoints.py

@@ -187,7 +187,6 @@ def write(
         tolerance: Optional[float] = 1e-4,
         username: Optional[str] = None,
         write_concurrency: Optional[Any] = None,
-        write_to_result_store: Optional[bool] = False,
     ) -> LeidenWriteResult:
         config = self._node_property_endpoints.create_base_config(
             G,
@@ -208,7 +207,6 @@ def write(
             theta=theta,
             tolerance=tolerance,
             username=username,
-            write_to_result_store=write_to_result_store,
         )
 
         result = self._node_property_endpoints.run_job_and_write(

graphdatascience/procedure_surface/cypher/clique_counting_cypher_endpoints.py

@@ -128,7 +128,6 @@ def write(
         sudo: Optional[bool] = False,
         username: Optional[str] = None,
         write_concurrency: Optional[int] = None,
-        write_to_result_store: Optional[bool] = False,
     ) -> CliqueCountingWriteResult:
         config = ConfigConverter.convert_to_gds_config(
             write_property=write_property,
@@ -140,7 +139,6 @@ def write(
             sudo=sudo,
             username=username,
             write_concurrency=write_concurrency,
-            write_to_result_store=write_to_result_store,
         )
 
         params = CallParameters(graph_name=G.name(), config=config)

graphdatascience/procedure_surface/cypher/kmeans_cypher_endpoints.py

@@ -193,7 +193,6 @@ def write(
         sudo: Optional[bool] = False,
         username: Optional[str] = None,
         write_concurrency: Optional[int] = None,
-        write_to_result_store: Optional[bool] = False,
     ) -> KMeansWriteResult:
         config = ConfigConverter.convert_to_gds_config(
             node_property=node_property,
@@ -214,7 +213,6 @@ def write(
             sudo=sudo,
             username=username,
             write_concurrency=write_concurrency,
-            write_to_result_store=write_to_result_store,
         )
 
         params = CallParameters(graph_name=G.name(), config=config)