У меня проблемы с изменением временного каталога в Dask.Когда я почему-то меняю временный каталог в dask.yaml, Dask все еще записывает в / tmp (который заполнен).Теперь я хочу попробовать и отладить это, но когда я использую client.get_worker_logs()
, я получаю только вывод INFO.
Я запускаю свой кластер с
from dask.distributed import LocalCluster, Client
cluster = LocalCluster(n_workers=1, threads_per_worker=4, memory_limit='10gb')
client = Client(cluster)
Я уже пытался добавить distributed.worker: debug
к distributed.yaml
, но это не меняет вывод.Я также проверяю, действительно ли я изменяю конфигурацию, вызывая dask.config.get('distributed.logging')
Что я делаю не так?