-
-
Notifications
You must be signed in to change notification settings - Fork 1.8k
Closed
Description
This just turned up -- I think this is likely related to @mrocklin's recent refactor to create high level graphs (#4092)
=================================== FAILURES ===================================
_____________________ TestDataArrayAndDataset.test_compute _____________________
self = <xarray.tests.test_dask.TestDataArrayAndDataset object at 0x7f5ed681ccc0>
def test_compute(self):
u = self.eager_array
v = self.lazy_array
assert dask.is_dask_collection(v)
> (v2,) = dask.compute(v + 1)
xarray/tests/test_dask.py:293:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
../../../miniconda/envs/test_env/lib/python3.6/site-packages/dask/base.py:395: in compute
dsk = collections_to_dsk(collections, optimize_graph, **kwargs)
../../../miniconda/envs/test_env/lib/python3.6/site-packages/dask/base.py:187: in collections_to_dsk
for opt, val in groups.items()}
../../../miniconda/envs/test_env/lib/python3.6/site-packages/dask/base.py:187: in <dictcomp>
for opt, val in groups.items()}
../../../miniconda/envs/test_env/lib/python3.6/site-packages/dask/base.py:212: in _extract_graph_and_keys
graph = merge(*graphs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
dicts = <dask.sharedict.ShareDict object at 0x7f5ed67fe6a0>, kwargs = {}
factory = <class 'dict'>, rv = {}
d = ('add-7645665a1ff2c665e611e02709f4873d', 0, 0)
def merge(*dicts, **kwargs):
""" Merge a collection of dictionaries
>>> merge({1: 'one'}, {2: 'two'})
{1: 'one', 2: 'two'}
Later dictionaries have precedence
>>> merge({1: 2, 3: 4}, {3: 3, 4: 4})
{1: 2, 3: 3, 4: 4}
See Also:
merge_with
"""
if len(dicts) == 1 and not isinstance(dicts[0], dict):
dicts = dicts[0]
factory = _get_factory(merge, kwargs)
rv = factory()
for d in dicts:
> rv.update(d)
E ValueError: dictionary update sequence element #0 has length 36; 2 is required
../../../miniconda/envs/test_env/lib/python3.6/site-packages/toolz/dicttoolz.py:39: ValueError
_____________________ TestDataArrayAndDataset.test_persist _____________________
self = <xarray.tests.test_dask.TestDataArrayAndDataset object at 0x7f5ed694e7b8>
def test_persist(self):
u = self.eager_array
v = self.lazy_array + 1
> (v2,) = dask.persist(v)
Metadata
Metadata
Assignees
Labels
No labels