pmap(func, its, client, lump=1, max_in_flight=3, name='compute')¶
Parallel map with back pressure.
Equivalent to this:
(func(x) for x in its)
func(x)runs concurrently on dask cluster.
Any) – Method that will be applied concurrently to data from
Client) – Connected dask client
int) – Group this many datasets into one task
int) – Maximum number of active tasks to submit
str) – Dask name for computation
- Return type