我有以下设置:一个返回数组的函数和一个Dask数组。 我想在for循环中调用函数,并用函数的返回值填充dask数组。这应该并行完成。import dask# do calculations and returns an array Xreturn some_array 我想以这种方式并行填充Dask数
我试图用脚本并行读取16个gzip文件的内容:import glob
from dask.distributed importw.compute()> TypeError: Delayed objects of unspecified length are not iterable
如何使用extend/append并行for循环,并将函数写入文档。所