- datacube.utils.dask.partition_map(n, func, its, name='compute')¶
Parallel map in lumps.
Partition sequence into lumps of size
n, then construct dask delayed computation evaluating to:
[func(x) for x in its[0:1n]], [func(x) for x in its[n:2n]], ... [func(x) for x in its[..]],
This is useful when you need to process a large number of small (quick) tasks (pixel drill for example).