Можно ли перезапустить клиент dask с новыми значениями (n_workers и threads_per_worker) - PullRequest
0 голосов
/ 20 марта 2020

Я хочу посмотреть, будет ли какое-либо улучшение производительности, если я продолжу изменять 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(), а затем импортировал новые комбинации в переменная кластера, но это зря.

...