Skip to content

Commit

Permalink
Add logging to StoreToZarr
Browse files Browse the repository at this point in the history
#656 
I also added the full target here, because that might be helpful to have?
  • Loading branch information
jbusecke authored Nov 29, 2023
1 parent 32d3864 commit 7223107
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions pangeo_forge_recipes/transforms.py
Original file line number Diff line number Diff line change
Expand Up @@ -547,6 +547,7 @@ def expand(
| beam.Map(self.dynamic_chunking_fn, **self.dynamic_chunking_fn_kwargs)
)
)
logger.warn(f"Storing Zarr with {target_chunks =} to {self.get_full_target()}")
rechunked_datasets = indexed_datasets | Rechunk(target_chunks=target_chunks, schema=schema)
target_store = schema | PrepareZarrTarget(
target=self.get_full_target(),
Expand Down

0 comments on commit 7223107

Please sign in to comment.