@@ -484,7 +484,7 @@ def group_cells_by_memory(clat_rad, max_memory_per_batch_gb=240.0):
484484 # Finalize current batch
485485 avg_mem_current = np .mean (current_batch_memory )
486486 # Use 30% safety margin for diskless NetCDF loading
487- safety_factor = 1.0
487+ safety_factor = 1.5
488488 n_workers = max (1 , int (max_memory_per_batch_gb / (avg_mem_current * safety_factor )))
489489 mem_per_worker = avg_mem_current * safety_factor
490490
@@ -509,7 +509,7 @@ def group_cells_by_memory(clat_rad, max_memory_per_batch_gb=240.0):
509509 if current_batch_indices :
510510 avg_mem = np .mean (current_batch_memory )
511511 # Use 30% safety margin for diskless NetCDF loading
512- safety_factor = 1.0
512+ safety_factor = 1.5
513513 n_workers = max (1 , int (max_memory_per_batch_gb / (avg_mem * safety_factor )))
514514 mem_per_worker = avg_mem * safety_factor
515515
@@ -570,8 +570,8 @@ def parallel_wrapper(grid, params, reader, writer, chunk_output_dir, clat_rad, c
570570 'description' : 'Generic laptop (16 threads, 16GB RAM)'
571571 },
572572 'dkrz_hpc' : {
573- 'total_cores' : 250 ,
574- 'total_memory_gb' : 240 .0 ,
573+ 'total_cores' : 52 ,
574+ 'total_memory_gb' : 510 .0 ,
575575 'netcdf_chunk_size' : 100 ,
576576 'threads_per_worker' : None , # Auto-compute based on worker memory
577577 'memory_per_cpu_mb' : None , # SLURM quota on interactive partition
@@ -715,8 +715,8 @@ def parallel_wrapper(grid, params, reader, writer, chunk_output_dir, clat_rad, c
715715 # cell_start = 0, cell_end = None → Process all cells (0 to n_cells-1)
716716 # cell_start = 2900, cell_end = 3000 → Process cells 2900-2999 only
717717 # cell_start = 0, cell_end = 100 → Process cells 0-99 only
718- cell_start = 0 # First cell to process (inclusive)
719- cell_end = None # Last cell to process (exclusive), None means process to end
718+ cell_start = 0 # First cell to process (inclusive)
719+ cell_end = None # Last cell to process (exclusive), None means process to end
720720 # ========================================================================
721721
722722 # Validate and set cell_end
0 commit comments