Align scaleNodeProperties stream output

Author: FlorentinD

graphdatascience/procedure_surface/api/catalog/scale_properties_endpoints.py

@@ -158,7 +158,7 @@ def stream(
         Returns
         -------
         DataFrame
-            DataFrame with nodeId and scaledProperties columns containing scaled property values.
+            DataFrame with nodeId and scaledProperty columns containing scaled property values.
             Each row represents a node with its corresponding scaled property values.
         """
         pass

graphdatascience/procedure_surface/arrow/catalog/scale_properties_arrow_endpoints.py

@@ -120,7 +120,10 @@ def stream(
             scaler=scaler_value,
         )
 
-        return self._node_property_endpoints.run_job_and_stream("v2/graph.nodeProperties.scale", G, config)
+        result = self._node_property_endpoints.run_job_and_stream("v2/graph.nodeProperties.scale", G, config)
+        result.rename(columns={"scaledProperties": "scaledProperty"}, inplace=True)
+
+        return result
 
     def write(
         self,

graphdatascience/tests/integrationV2/procedure_surface/arrow/catalog/test_scale_properties_arrow_endpoints.py

@@ -76,7 +76,7 @@ def test_scale_properties_stream(
         G=sample_graph, node_properties=["prop1"], scaler=ScalerConfig(type="Log", offset=1.0)
     )
 
-    assert set(result_df.columns) == {"nodeId", "scaledProperties"}
+    assert set(result_df.columns) == {"nodeId", "scaledProperty"}
     assert len(result_df) == 3  # We have 3 nodes
 
 

graphdatascience/tests/integrationV2/procedure_surface/cypher/catalog/test_scale_properties_cypher_endpoints.py

@@ -60,7 +60,7 @@ def test_scale_properties_stream(
         G=sample_graph, node_properties=["prop1"], scaler=ScalerConfig(type="Log", offset=1.0)
     )
 
-    assert set(result_df.columns) == {"nodeId", "scaledProperties"}
+    assert set(result_df.columns) == {"nodeId", "scaledProperty"}
     assert len(result_df) == 3  # We have 3 nodes