Увидеть логи рабочих. - PullRequest
0 голосов
/ 19 сентября 2019

У меня проблемы с изменением временного каталога в 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')

Что я делаю не так?

1 Ответ

0 голосов
/ 21 сентября 2019

По умолчанию LocalCluster отключает большинство журналов.Попробуйте передать ключевое слово silence_logs=False

cluster = LocalCluster(..., silence_logs=False)
...