Local Desktop Dask Cluster#
import os
from dask.distributed import Client, LocalCluster
cluster = LocalCluster(threads_per_worker=os.cpu_count())
client = Client(cluster)
print(f'dask dashboard available at: {client.dashboard_link}')
import os
from dask.distributed import Client, LocalCluster
cluster = LocalCluster(threads_per_worker=os.cpu_count())
client = Client(cluster)
print(f'dask dashboard available at: {client.dashboard_link}')