fixup

Author: ray-chew

runs/icon_etopo_global.py

@@ -482,7 +482,7 @@ def group_cells_by_memory(clat_rad, max_memory_per_batch_gb=240.0):
                 # Finalize current batch
                 avg_mem_current = np.mean(current_batch_memory)
                 # Use 30% safety margin for diskless NetCDF loading
-                safety_factor = 1.3
+                safety_factor = 1.0
                 n_workers = max(1, int(max_memory_per_batch_gb / (avg_mem_current * safety_factor)))
                 mem_per_worker = avg_mem_current * safety_factor
 
@@ -507,7 +507,7 @@ def group_cells_by_memory(clat_rad, max_memory_per_batch_gb=240.0):
     if current_batch_indices:
         avg_mem = np.mean(current_batch_memory)
         # Use 30% safety margin for diskless NetCDF loading
-        safety_factor = 1.3
+        safety_factor = 1.0
         n_workers = max(1, int(max_memory_per_batch_gb / (avg_mem * safety_factor)))
         mem_per_worker = avg_mem * safety_factor