rename env to settings

Author: tasansal

src/mdio/converters/mdio.py

@@ -68,7 +68,7 @@ def mdio_to_segy(  # noqa: PLR0912, PLR0913, PLR0915
         >>> output_path = UPath("prefix/file.segy")
         >>> mdio_to_segy(input_path, output_path)
     """
-    env = MDIOSettings()
+    settings = MDIOSettings()
 
     input_path = _normalize_path(input_path)
     output_path = _normalize_path(output_path)
@@ -145,7 +145,7 @@ def mdio_to_segy(  # noqa: PLR0912, PLR0913, PLR0915
             if client is not None:
                 block_records = block_records.compute()
             else:
-                block_records = block_records.compute(num_workers=env.export_cpus)
+                block_records = block_records.compute(num_workers=settings.export_cpus)
 
         ordered_files = [rec.path for rec in block_records.ravel() if rec != 0]
         ordered_files = [output_path] + ordered_files

src/mdio/converters/segy.py

@@ -92,17 +92,17 @@ def grid_density_qc(grid: Grid, num_traces: int) -> None:
         GridTraceSparsityError: If the sparsity ratio exceeds `MDIO__GRID__SPARSITY_RATIO_LIMIT`
             and `MDIO_IGNORE_CHECKS` is not set to a truthy value (e.g., "1", "true").
     """
-    env = MDIOSettings()
+    settings = MDIOSettings()
     # Calculate total possible traces in the grid (excluding sample dimension)
     grid_traces = np.prod(grid.shape[:-1], dtype=np.uint64)
 
     # Handle division by zero if num_traces is 0
     sparsity_ratio = float("inf") if num_traces == 0 else grid_traces / num_traces
 
     # Fetch and validate environment variables
-    warning_ratio = env.grid_sparsity_ratio_warn
-    error_ratio = env.grid_sparsity_ratio_limit
-    ignore_checks = env.ignore_checks
+    warning_ratio = settings.grid_sparsity_ratio_warn
+    error_ratio = settings.grid_sparsity_ratio_limit
+    ignore_checks = settings.ignore_checks
 
     # Check sparsity
     should_warn = sparsity_ratio > warning_ratio
@@ -360,9 +360,9 @@ def _populate_coordinates(
 
 
 def _add_segy_file_headers(xr_dataset: xr_Dataset, segy_file_info: SegyFileInfo) -> xr_Dataset:
-    env = MDIOSettings()
+    settings = MDIOSettings()
 
-    if not env.save_segy_file_header:
+    if not settings.save_segy_file_header:
         return xr_dataset
 
     expected_rows = 40
@@ -386,7 +386,7 @@ def _add_segy_file_headers(xr_dataset: xr_Dataset, segy_file_info: SegyFileInfo)
             "binaryHeader": segy_file_info.binary_header_dict,
         }
     )
-    if env.raw_headers:
+    if settings.raw_headers:
         raw_binary_base64 = base64.b64encode(segy_file_info.raw_binary_headers).decode("ascii")
         xr_dataset["segy_file_header"].attrs.update({"rawBinaryHeader": raw_binary_base64})
 
@@ -524,7 +524,7 @@ def segy_to_mdio(  # noqa PLR0913
     Raises:
         FileExistsError: If the output location already exists and overwrite is False.
     """
-    env = MDIOSettings()
+    settings = MDIOSettings()
 
     _validate_spec_in_template(segy_spec, mdio_template)
 
@@ -555,7 +555,7 @@ def segy_to_mdio(  # noqa PLR0913
     _, non_dim_coords = _get_coordinates(grid, segy_headers, mdio_template)
     header_dtype = to_structured_type(segy_spec.trace.header.dtype)
 
-    if env.raw_headers:
+    if settings.raw_headers:
         if zarr.config.get("default_zarr_format") == ZarrFormat.V2:
             logger.warning("Raw headers are only supported for Zarr v3. Skipping raw headers.")
         else:

src/mdio/segy/_workers.py

@@ -46,13 +46,13 @@ def header_scan_worker(
     Returns:
         HeaderArray parsed from SEG-Y library.
     """
-    env = MDIOSettings()
+    settings = MDIOSettings()
 
     segy_file = SegyFileWrapper(**segy_file_kwargs)
 
     slice_ = slice(*trace_range)
 
-    trace_header = segy_file.trace[slice_].header if env.cloud_native else segy_file.header[slice_]
+    trace_header = segy_file.trace[slice_].header if settings.cloud_native else segy_file.header[slice_]
 
     if subset is not None:
         # struct field selection needs a list, not a tuple; a subset is a tuple from the template.

src/mdio/segy/blocked_io.py

@@ -69,7 +69,7 @@ def to_zarr(  # noqa: PLR0913, PLR0915
     Returns:
         None
     """
-    env = MDIOSettings()
+    settings = MDIOSettings()
 
     data = dataset[data_variable_name]
 
@@ -82,7 +82,7 @@ def to_zarr(  # noqa: PLR0913, PLR0915
 
     # For Unix async writes with s3fs/fsspec & multiprocessing, use 'spawn' instead of default
     # 'fork' to avoid deadlocks on cloud stores. Slower but necessary. Default on Windows.
-    num_workers = min(num_chunks, env.import_cpus)
+    num_workers = min(num_chunks, settings.import_cpus)
     context = mp.get_context("spawn")
     executor = ProcessPoolExecutor(max_workers=num_workers, mp_context=context)
 

src/mdio/segy/parsers.py

@@ -40,7 +40,7 @@ def parse_headers(
         HeaderArray. Keys are the index names, values are numpy arrays of parsed headers for the
         current block. Array is of type byte_type except IBM32 which is mapped to FLOAT32.
     """
-    env = MDIOSettings()
+    settings = MDIOSettings()
 
     trace_count = num_traces
     n_blocks = int(ceil(trace_count / block_size))
@@ -52,7 +52,7 @@ def parse_headers(
 
         trace_ranges.append((start, stop))
 
-    num_workers = min(n_blocks, env.import_cpus)
+    num_workers = min(n_blocks, settings.import_cpus)
 
     tqdm_kw = {"unit": "block", "dynamic_ncols": True}
     # For Unix async writes with s3fs/fsspec & multiprocessing, use 'spawn' instead of default