Указание клиента для использования с dask.config

Question

Новая конфигурация Dask поощряет использование именованного scheduler. Это хорошо работает для потоков, многопроцессорной обработки и т. Д. Также не рекомендуется использовать get, что является разумным. Однако это поднимает следующий вопрос.

Если у вас есть несколько разных распределенных клиентов Dask, которые можно использовать для вычислений, как выбрать одного клиента для использования в контексте?

Answer 1

По состоянию на dask.__version__ == 0.18.1 нет однозначного ответа на это. Сегодня существует два функциональных ответа, но неясно, как это разрешится в будущем.

1. Продолжайте использовать get=

   with dask.config.set(get=my_preferred_client.get):
       ...
   

2. Использование distributed.client.temp_default_client

   from distributed.client import temp_default_client
   with temp_default_client(my_preferred_client):
       ...
   

Однако я бы не ожидал, что какой-либо из этих методов выживет навсегда. Ходили разговоры о построении другого протокола для планировщиков, но эта работа не была выполнена (по состоянию на 2018-06-29, как всегда, вы должны проверять документацию на наличие последних ответов).