Я хочу посмотреть, будет ли какое-либо улучшение производительности, если я продолжу изменять n_workers
и threads_per_client
.
import dask.dataframe as dd
from dask.distributed import Client, LocalCluster
cluster = LocalCluster(n_workers=8, threads_per_worker=5)
client = Client(cluster)
...
cluster = LocalCluster(n_workers=5, threads_per_worker=8)
client = Client(cluster)
...
Я попытался с client.restart()
и client.shutdown()
, а затем импортировал новые комбинации в переменная кластера, но это зря.