Local Desktop Dask Cluster

import os
from dask.distributed import Client, LocalCluster

cluster = LocalCluster(threads_per_worker=os.cpu_count())
client = Client(cluster)