fix: fixed aggregate_spatial_window arguments

openeo_driver/ProcessGraphDeserializer.py

@@ -1518,9 +1518,9 @@ def aggregate_spatial_window(args: ProcessArgs, env: EvalEnv) -> DriverDataCube:
     reduce_pg = args.get_deep("reducer", "process_graph", expected_type=dict)
     window_size = args.get_required("size")
     align = args.get_optional("align", default="upper-left")
-    pad = args.get_optional("pad", default="pad")
+    boundary = args.get_optional("boundary", default="pad")
     context = args.get_optional("context", default=None)
-    return cube.aggregate_spatial_window(reducer=reduce_pg, size=window_size, align=align, pad=pad, context=context)
+    return cube.aggregate_spatial_window(reducer=reduce_pg, size=window_size, align=align, boundary=boundary, context=context)
 
 @process
 def mask(args: ProcessArgs, env: EvalEnv) -> DriverDataCube:

openeo_driver/datacube.py

@@ -202,6 +202,15 @@ def aggregate_spatial(
         # TODO: drop `target_dimension`? see https://github.com/Open-EO/openeo-processes/issues/366
         self._not_implemented()
 
+    def aggregate_spatial_window(
+        self,
+        size,
+        reducer: dict,
+        align: str="upper-left",
+        boundary: str = "pad"
+    )  -> "DriverDataCube":
+        self._not_implemented()
+
     def ndvi(self, nir: str = "nir", red: str = "red", target_band: Optional[str] = None) -> "DriverDataCube":
         self._not_implemented()
 

openeo_driver/dry_run.py

@@ -654,6 +654,17 @@ def aggregate_spatial(
             cube = self.filter_bbox(**bbox, operation="weak_spatial_extent")
         return cube._process(operation="aggregate_spatial", arguments={"geometries": geometries})
 
+    def aggregate_spatial_window(
+        self,
+        size,
+        reducer: dict,
+        align: str="upper-left",
+        boundary: str = "pad"
+    )  -> "DriverDataCube":
+        cube = self
+        return cube._process(operation="aggregate_spatial_window", arguments={"size": size, "reducer": reducer, "align": align, "boundary": boundary})
+
+
     def _normalize_geometry(
         self, geometries, target_crs=None, target_resolution = None
     ) -> Tuple[Union[DriverVectorCube, DelayedVector, BaseGeometry], dict]: