Skip to content

Commit 3e56e3d

Browse files
authored
Refactor sanitize_encoding function parameters
1 parent 4386b7a commit 3e56e3d

File tree

1 file changed

+3
-5
lines changed

1 file changed

+3
-5
lines changed

src/satellite_consumer/storage.py

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,6 @@
88
import fsspec
99
import gcsfs
1010
import icechunk
11-
import numpy as np
1211
import pandas as pd
1312
import s3fs
1413
import xarray as xr
@@ -24,11 +23,10 @@
2423

2524
def sanitize_encoding(
2625
ds: xr.Dataset,
26+
dims: list[str],
2727
data: dict[str, Any],
2828
) -> dict[str, Any]:
2929
"""Get the encoding dictionary for writing the dataset to Zarr."""
30-
dims: list[str] = encoding["_ARRAY_DIMENSIONS"]
31-
3230
if isinstance(data, dict):
3331
for key, value in data.items():
3432
if key in ["chunks", "shards"] and isinstance(value, list):
@@ -85,7 +83,7 @@ def write_to_store(
8583
obj=ds,
8684
session=session,
8785
mode="w-",
88-
encoding=sanitize_encoding(ds=ds, encoding=encoding),
86+
encoding=sanitize_encoding(ds=ds, dims=dims, encoding=encoding),
8987
)
9088
_ = session.commit(message="initial commit")
9189
elif isinstance(dst, str):
@@ -96,7 +94,7 @@ def write_to_store(
9694
write_empty_chunks=False,
9795
zarr_format=3,
9896
compute=True,
99-
encoding=sanitize_encoding(ds=ds, encoding=encoding),
97+
encoding=sanitize_encoding(ds=ds, dims=dims, encoding=encoding),
10098
)
10199
return None
102100

0 commit comments

Comments
 (0)