Changes according to review
MODIFY
pangeo_forge/recipe.py
pangeo_forge/recipe.py
@@ -160,8 +160,8 @@ class NetCDFtoZarrSequentialRecipe(BaseRecipe):
xarray_concat_kwargs: dict = field(default_factory=dict)
delete_input_encoding: bool = True
fsspec_open_kwargs: dict = field(default_factory=dict)
- process_input: Optional[Callable[[xr.Dataset, str], xr.Dataset] = None
- process_chunk: Optional[callable] = None
+ process_input: Optional[Callable[[xr.Dataset, str], xr.Dataset]] = None
+ process_chunk: Optional[Callable[[xr.Dataset], xr.Dataset]] = None
def __post_init__(self):
self._chunks_inputs = {

MODIFY
tests/test_recipe.py
tests/test_recipe.py
@@ -8,7 +8,7 @@ from pangeo_forge.storage import UninitializedTargetError
dummy_fnames = ["a.nc", "b.nc", "c.nc"]
-def incr_date(ds, fname=""):
+def incr_date(ds, filename=""):
# add one day
t = [d + int(24 * 3600e9) for d in ds.time.values]
ds = ds.assign_coords(time=t)

Changes according to review