Skip to content

Commit b88a612

Browse files
committed
fix parallelism of dmap
nested broadcasts are fusing together, which is not what we really want here
1 parent 5bd8cfd commit b88a612

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

src/base.jl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -310,7 +310,7 @@ Call a function `fn` on `workers`, with a single parameter arriving from the
310310
corresponding position in `arr`.
311311
"""
312312
function dmap(arr::Vector, fn, workers)
313-
fetch.([get_from(w, :($fn($(arr[i])))) for (i, w) in enumerate(workers)])
313+
map(fetch, [get_from(w, :($fn($(arr[i])))) for (i, w) in enumerate(workers)])
314314
end
315315

316316
"""

0 commit comments

Comments
 (0)