initiate dask 1

initiate dask

from dask.distributed import Client

client=Client(threads_per_worker=4, n_workers=24, processes=True)

#check status
client

Here is what the above code is Doing:
1. We’re creating a Client object.
2. We’re telling the Client object to use 4 threads per worker.
3. We’re telling the Client object to use 24 workers.
4. We’re telling the Client object to use processes instead of threads.

Similar Posts