sar_backscatter: print partitioner in test, may need an assert

#1018
Open-EO · Jan 27, 2025 · acb4e77 · acb4e77
1 parent f19a484
commit acb4e77
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/openeogeotrellis/collections/s1backscatter_orfeo.py b/openeogeotrellis/collections/s1backscatter_orfeo.py
@@ -1034,12 +1034,14 @@ def partitionByPath(tuple):
             metadata=layer_metadata_py
         )
 
+        the_rdd = tile_layer.srdd.rdd()
+        print(f"Partitioner is present {str(partitioner)}")
+        logger.info(f"Partitioner is present {str(partitioner)}")
         if(partitioner.isPresent()):
-            logger.info(f"Partitioner is present {str(partitioner)}")
-            tile_layer.srdd.rdd().partitionBy(partitioner.get())
+            the_rdd = tile_layer.srdd.rdd().partitionBy(partitioner.get())
 
         # Merge any keys that have more than one tile.
-        contextRDD = self.jvm.org.openeo.geotrellis.OpenEOProcesses().mergeTiles(tile_layer.srdd.rdd())
+        contextRDD = self.jvm.org.openeo.geotrellis.OpenEOProcesses().mergeTiles(the_rdd)
         temporal_tiled_raster_layer = self.jvm.geopyspark.geotrellis.TemporalTiledRasterLayer
         srdd = temporal_tiled_raster_layer.apply(self.jvm.scala.Option.apply(zoom), contextRDD)
         merged_tile_layer = geopyspark.TiledRasterLayer(geopyspark.LayerType.SPACETIME, srdd)