Skip to content

Commit ce62eee

Browse files
committed
flatten keys
1 parent 092daa6 commit ce62eee

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

distributed/client.py

+2-2
Original file line numberDiff line numberDiff line change
@@ -3667,8 +3667,8 @@ def compute(
36673667
expr = FinalizeCompute(expr)
36683668

36693669
expr = expr.optimize()
3670-
3671-
names = expr.__dask_keys__()
3670+
# FIXME: Is this actually required?
3671+
names = list(flatten(expr.__dask_keys__()))
36723672

36733673
futures_dict = self._graph_to_futures(
36743674
expr,

0 commit comments

Comments
 (0)