File tree Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Original file line number Diff line number Diff line change @@ -110,13 +110,14 @@ def trace_worker( # noqa: PLR0913
110110 SummaryStatistics object containing statistics about the written traces.
111111 """
112112 global _worker_segy_file
113- # Setting the zarr config to 1 thread to ensure we honor the `MDIO__IMPORT__CPU_COUNT` environment variable.
114- # The Zarr 3 engine utilizes multiple threads. This can lead to resource contention and unpredictable memory usage.
115- zarr_config .set ({"threading.max_workers" : 1 })
116113
117114 # Use the pre-opened segy file from worker initialization
118115 segy_file = _worker_segy_file
119116
117+ # Setting the zarr config to 1 thread to ensure we honor the `MDIO__IMPORT__CPU_COUNT` environment variable.
118+ # The Zarr 3 engine utilizes multiple threads. This can lead to resource contention and unpredictable memory usage.
119+ zarr_config .set ({"threading.max_workers" : 1 })
120+
120121 region_slices = tuple (region .values ())
121122 local_grid_map = grid_map [region_slices [:- 1 ]] # minus last (vertical) axis
122123
You can’t perform that action at this time.
0 commit comments