Method create

benchmarks/src/environment/dask.py:38–40

(count: int, n_processes: int = 1, **kwargs)

    @staticmethod
    def create(count: int, n_processes: int = 1, **kwargs) -> "DaskWorkerConfig":
        assert count % n_processes == 0
        return DaskWorkerConfig(processes=n_processes, threads_per_process=count // n_processes, **kwargs)


@dataclasses.dataclass(frozen=True)