Как назначить задачи конкретному c работнику в кластере dask yarn

Question

Аналог этого вопроса для dask.distributed можно найти здесь: Как назначить задачи конкретному c worker внутри Dask.Distributed

Но тот же прием не похоже, работает для группы пряжи dask. Есть ли способ сделать это в случае dask кластера пряжи? Т.е. назначить задачу указанному c worker в конкретном c узле с определенным IP-адресом?

Answer 1

Я отвечу на свой вопрос. Короче пост, который я выложил по ссылке, ДЕЙСТВИТЕЛЬНО работает. Но вы должны убедиться, что метод, который вы назначаете работнику, получает разные аргументы. В противном случае он будет запущен в том же контейнере.