Fixed the interpolation function to not use chunking (#129)

OceanStreamIO · Nov 10, 2023 · 527ec12 · 527ec12
1 parent 5a5b795
commit 527ec12
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/oceanstream/L2_calibrated_data/sv_interpolation.py b/oceanstream/L2_calibrated_data/sv_interpolation.py
@@ -54,7 +54,10 @@ def interpolate_sv(
         dataset = read_processed(path_to_file)
 
     # Retrieve the Sv DataArray from the dataset
-    sv_dataarray = dataset["Sv"].chunk({"ping_time": -1})
+    # sv_dataarray = dataset["Sv"].chunk({"ping_time": -1})
+    # Ensure the data is loaded into memory as a regular array (not Dask chunked)
+    sv_dataarray = dataset["Sv"]
+    sv_dataarray = sv_dataarray.load()
 
     # Initialize an empty list to store the processed channels
     processed_channels = []