Function create_dask_worker

benchmarks/experiment-dask.py:27–32

(cores: int, n_processes: int)

def create_dask_worker(cores: int, n_processes: int) -> DaskWorkerConfig:
    return DaskWorkerConfig.create(
        count=cores,
        n_processes=n_processes,
        init_cmd=["source /mnt/proj1/dd-23-154/beranekj/hyperqueue/modules.sh"],
    )


@register_case(cli)