Skip to content

Commit

Permalink
Limit caching concurrency for climsim recipe (#44)
Browse files Browse the repository at this point in the history
* use limit concurrency branch of recipes

* set max concurrency=20
  • Loading branch information
cisaacstern committed Aug 9, 2023
1 parent 25ff6e5 commit 32de8c2
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 2 deletions.
2 changes: 1 addition & 1 deletion feedstock/climsim.py
Original file line number Diff line number Diff line change
Expand Up @@ -149,7 +149,7 @@ def expand(self, pcoll: beam.PCollection) -> beam.PCollection:
# FIXME: rate limiting on caching step is probably required to get this to run
# end-to-end, without globally capping workers at a low value for all stages,
# see discussion in: https://github.com/leap-stc/data-management/issues/36.
| OpenURLWithFSSpec()
| OpenURLWithFSSpec(max_concurrency=20)
| OpenWithXarray(
# FIXME: Get files to open without `copy_to_local=True`
# Related: what is the filetype? Looks like netcdf3, but for some reason
Expand Down
5 changes: 4 additions & 1 deletion feedstock/requirements.txt
Original file line number Diff line number Diff line change
Expand Up @@ -3,4 +3,7 @@
# https://github.com/leap-stc/data-management/pull/33 (see PR discussion for details).
# once a `0.10.1` release of `pangeo-forge-recipes` is available that includes this fix, we should
# install from that release instead.
git+https://github.com/pangeo-forge/pangeo-forge-recipes.git@a22e6aafc938be05809b55d9a3fced5598e71698
# git+https://github.com/pangeo-forge/pangeo-forge-recipes.git@a22e6aafc938be05809b55d9a3fced5598e71698

# temporarily point to this PR branch to evaluate it in a real world use case
git+https://github.com/pangeo-forge/pangeo-forge-recipes.git@limit-concurrency

0 comments on commit 32de8c2

Please sign in to comment.