swot_simulator.dispatch.compute#

swot_simulator.dispatch.compute(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 – Variable length argument list.

  • **kwargs – Arbitrary keyword arguments.

Returns

The result of the execution of the functions.

Return type

list