swot_simulator.dispatch.compute¶
-
swot_simulator.dispatch.
compute
(client: distributed.client.Client, func: Callable, seq: Iterator, *args, **kwargs) → List[Any][source]¶ Distribute the execution of functions to free workers, i.e. those who do not perform any tasks.
- Parameters
client (dask.distributed.Client) – Client connected to the Dask cluster.
func (callable) – Function to execute
seq (iterable) – The sequence of arguments handled by
func
.*args – any Extra arguments and keyword arguments to pass to
func
.**kwargs –
any Extra arguments and keyword arguments to pass to
func
.
- Returns
The result of the execution of the functions.
- Return type