espnet3.parallel.parallel.set_parallel

source

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

Set the global Dask cluster using the provided configuration.

• Parameters:config (DictConfig | None) – Configuration object with ‘env’ and cluster options. If None, defaults to a local single-worker configuration.

Example

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

• Returns: None