adding logging

pangeo-forge · Mar 13, 2024 · 967e6eb · 967e6eb
1 parent bbbeb1a
commit 967e6eb
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/pangeo_forge_recipes/transforms.py b/pangeo_forge_recipes/transforms.py
@@ -681,7 +681,7 @@ def expand(
                 | beam.Map(self.dynamic_chunking_fn, **self.dynamic_chunking_fn_kwargs)
             )
         )
-        logger.info(f"Storing Zarr with {target_chunks =} to {self.get_full_target()}")
+        logger.warning(f"Storing Zarr with {target_chunks =} to {self.get_full_target()}")
 
         rechunked_datasets = indexed_datasets | Rechunk(target_chunks=target_chunks, schema=schema)
 

diff --git a/pangeo_forge_recipes/writers.py b/pangeo_forge_recipes/writers.py
@@ -209,6 +209,8 @@ def get_full_target(self: ZarrWriterProtocol) -> FSSpecTarget:
             target_root = self.target_root
         return target_root / self.store_name
 
+import logging
+logger = logging.getLogger(__name__)
 
 def create_pyramid(
     item: Tuple[Index, xr.Dataset],
@@ -231,6 +233,7 @@ def create_pyramid(
     # For now, we can use ds.rename
     if rename_spatial_dims:
         ds = ds.rename(rename_spatial_dims)
+    logger.warning("reprojecting")
 
     level_ds = level_reproject(ds, level=level, **pyramid_kwargs)