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

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

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

dask,dask-distributed,

2

Ответов: 1


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, как всегда, вы должны проверить документацию на наличие современных ответов).

удар, пощечина-распределенная,
Похожие вопросы