Как я могу назначить работу для указанного c кластера, используя его имя

Question

Я сделал локальный кластер с 8 работниками. Теперь я хочу, чтобы конкретное c задание было отправлено конкретным c работникам. Как я могу сделать это в локальном кластере?

Answer 1

https://distributed.dask.org/en/latest/api.html#distributed .Client.run

Ограничить вычисления определенными работниками с аргументом ключевых слов работников =

>>> c.run(os.getpid, workers=['192.168.0.100:9000',
...                           '192.168.0.101:9000'])  # doctest: +SKIP
{'192.168.0.100:9000': 1234,
 '192.168.0.101:9000': 4321}

Вы также можете сделать это с помощью resources: https://distributed.dask.org/en/latest/resources.html#example