Skip to content

Commit

Permalink
Issue #276 fix dry run of aggregate_spatial
Browse files Browse the repository at this point in the history
  • Loading branch information
JeroenVerstraelen committed Mar 27, 2024
1 parent 0f42008 commit 7209e97
Showing 1 changed file with 6 additions and 7 deletions.
13 changes: 6 additions & 7 deletions openeo_driver/dry_run.py
Original file line number Diff line number Diff line change
Expand Up @@ -544,19 +544,18 @@ def mask_polygon(self, mask, replacement=None, inside: bool = False) -> 'DriverD
return cube._process(operation="mask_polygon", arguments={"mask": mask})

def aggregate_spatial(
self,
geometries: Union[BaseGeometry, str, DriverVectorCube],
reducer: dict,
target_dimension: str = "result",
) -> Union[AggregatePolygonResult, AggregatePolygonSpatialResult]:
self,
geometries: Union[BaseGeometry, str, DriverVectorCube],
reducer: dict,
target_dimension: str = "result",
) -> "DryRunDataCube":
# TODO #71 #114 EP-3981 normalize to vector cube instead of GeometryCollection
geoms_is_empty = isinstance(geometries, DriverVectorCube) and len(geometries.get_geometries()) == 0
cube = self
if not geoms_is_empty:
geometries, bbox = self._normalize_geometry(geometries)
cube = self.filter_bbox(**bbox, operation="_weak_spatial_extent")
cube._process(operation="aggregate_spatial", arguments={"geometries": geometries})
return cube
return cube._process(operation="aggregate_spatial", arguments={"geometries": geometries})

def _normalize_geometry(self, geometries) -> Tuple[Union[DriverVectorCube, DelayedVector, BaseGeometry], dict]:
"""
Expand Down

0 comments on commit 7209e97

Please sign in to comment.