Remove the dask client restart at the beginning of each time chunk processing

2025-09-29 11:03:13 +02:00
parent da275cdc97
commit b97be2dff3
1 changed files with 1 additions and 1 deletions
--- a/scripts/sp2xr_pipeline.py
+++ b/scripts/sp2xr_pipeline.py
@@ -130,7 +130,7 @@ def main():
                pbp_filters.append(("hour", ">=", chunk_start.hour))
                pbp_filters.append(("hour", "<", chunk_end.hour))

-            #client.restart()
+            # client.restart()

            scattered_bins = {
                "inc_mass_bin_lims": client.scatter(inc_mass_bin_lims, broadcast=True),