Skip to content

Commit

Permalink
Ready to test dataflow
Browse files Browse the repository at this point in the history
  • Loading branch information
jbusecke committed Oct 17, 2024
1 parent a5370cf commit 8ef1232
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion feedstock/recipe.py
Original file line number Diff line number Diff line change
Expand Up @@ -42,14 +42,15 @@
# small recipe
recipe = (
beam.Create(pattern_a.items())
| OpenURLWithFSSpec()
| OpenURLWithFSSpec(open_kwargs={'cache_type':'none'})
| OpenWithXarray()
| StoreToZarr(
store_name="chirps-global-daily.zarr",
# FIXME: This is brittle. it needs to be named exactly like in meta.yaml...
# Can we inject this in the same way as the root?
# Maybe its better to find another way and avoid injections entirely...
combine_dims=pattern_a.combine_dim_keys,
target_chunks={'time':10, 'longitude':2400, 'latitude':1000},
)
| InjectAttrs()
| ConsolidateDimensionCoordinates()
Expand Down

0 comments on commit 8ef1232

Please sign in to comment.