espnet3.parallel.parallel.set_parallel

source

espnet3.parallel.parallel.set_parallel(config: DictConfig) → None

Set the global Dask cluster using the provided configuration.

• Parameters:config (DictConfig) – Configuration object with ‘env’ and cluster options.

Example

>>> from omegaconf import OmegaConf
>>> config = OmegaConf.create({'env': 'local', 'n_workers': 2})
>>> set_parallel(config)