from dask_jobqueue import SLURMCluster
cluster = SLURMCluster(processes=4, threads=2, memory="16GB", project="woodshole", walltime="01:00", queue="normal")
cluster.start_workers(8)
[2, 3, 4, 5, 6, 7, 8, 9]
from dask.distributed import Client
client = Client(cluster)
client
Client
|
Cluster
|