Skip to content
Snippets Groups Projects

Add dask-client configurations as resources

3 files
+ 19
62
Compare changes
  • Side-by-side
  • Inline

Files

from dask.distributed import Client
from bob.pipelines.distributed.sge import SGEMultipleQueuesCluster
from bob.pipelines.distributed.sge_queues import QUEUE_DEMANDING
cluster = SGEMultipleQueuesCluster(min_jobs=20, sge_job_spec=QUEUE_DEMANDING)
dask_client = Client(cluster)
Loading