Worker and Scheduler Options#
You can also pass any configuration options down to the Dask Worker or
Scheduler classes using the scheduler_options
and worker_options
keywords. Here are a couple of examples:
cluster = coiled.Cluster(
...
worker_options={"nthreads": 1}, # common when running multi-threaded applications
scheduler_options={"idle_timeout": "2 hours"},
)
client = cluster.get_client()