We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
HighLevelGraph
Layer
1 parent 600ef7b commit 020345dCopy full SHA for 020345d
xarray/core/parallel.py
@@ -540,10 +540,14 @@ def subset_dataset_to_block(
540
dependencies=[arg for arg in npargs if dask.is_dask_collection(arg)],
541
)
542
543
- for gname_l, layer in new_layers.items():
544
- # This adds in the getitems for each variable in the dataset.
545
- hlg.dependencies[gname_l] = {gname}
546
- hlg.layers[gname_l] = layer
+ # This adds in the getitems for each variable in the dataset.
+ hlg = HighLevelGraph(
+ {**hlg.layers, **new_layers},
+ dependencies={
547
+ **hlg.dependencies,
548
+ **{name: {gname} for name in new_layers.keys()},
549
+ },
550
+ )
551
552
result = Dataset(coords=indexes, attrs=template.attrs)
553
for index in result.indexes:
0 commit comments