dask_unpack

dask_unpack(client, result_future, n)[source]

Unpack dask future of iterable

Parameters:

client – dask client
result_future – future to unpack
n – number of items to unpack

Returns:

list of unpacked futures