-
-
Notifications
You must be signed in to change notification settings - Fork 1.1k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Support HighLevelGraphs #2603
Support HighLevelGraphs #2603
Conversation
Hello @mrocklin! Thanks for submitting the PR.
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks Matt!
xarray/core/dataset.py
Outdated
|
||
def __dask_keys__(self): | ||
import dask | ||
return [v.__dask_keys__() for v in self.variables.values() | ||
if dask.is_dask_collection(v)] | ||
|
||
def __dask_layers__(self): | ||
return sum([v.__dask_layers__() for v in self.variables.values() if | ||
dask.is_dask_collection(v)], []) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I think you need to add a local import dask
here since dask isn't a hard dependency. This suggests there isn't any coverage for this new method -- is there any easy way to add that?
thanks! |
* upstream/master: Feature: N-dimensional auto_combine (pydata#2553) Support HighLevelGraphs (pydata#2603) Bump cftime version in doc environment (pydata#2604) use keep_attrs in binary operations II (pydata#2590) Temporarily mark dask-dev build as an allowed failure (pydata#2602) Fix wrong error message in interp() (pydata#2598) Add dayofyear and dayofweek accessors (pydata#2599) Fix h5netcdf saving scalars with filters or chunks (pydata#2591) Minor update to PR template (pydata#2596) Zarr consolidated (pydata#2559) fix examples (pydata#2581) Fix typo (pydata#2578) Concat docstring typo (pydata#2577) DOC: remove example using Dataset.T (pydata#2572) python setup.py test now works by default (pydata#2573) Return slices when possible from CFTimeIndex.get_loc() (pydata#2569) DOC: fix computation.rst (pydata#2567)
Fixes dask/dask#4291
whats-new.rst
for all changes andapi.rst
for new API