osl_ephys.utils.parallel#

Utility functions for parallel processing.

Attributes#

osl_logger

Functions#

dask_parallel_bag(func, iter_args[, func_args, ...])

A maybe more consistent alternative to dask_parallel.

Module Contents#

osl_ephys.utils.parallel.osl_logger = None[source]#
osl_ephys.utils.parallel.dask_parallel_bag(func, iter_args, func_args=None, func_kwargs=None)[source]#

A maybe more consistent alternative to dask_parallel.

Parameters:

  • func (function) – The function to run in parallel.

  • iter_args (list) – A list of iterables to pass to func.

  • func_args (list, optional) – A list of positional arguments to pass to func.

  • func_kwargs (dict, optional) – A dictionary of keyword arguments to pass to func.

Returns:

flags – A list of return values from func.

Return type:

list

References

https://docs.dask.org/en/stable/bag.html