swot_simulator.dispatch.compute

swot_simulator.dispatch.compute(client: distributed.client.Client, func: Callable, seq: Iterator, *args, **kwargs) → List[Any]

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 – Variable length argument list.

• **kwargs – Arbitrary keyword arguments.

Returns

The result of the execution of the functions.

Return type

list