Убийственные задания, порожденные работой - PullRequest
0 голосов
/ 30 сентября 2018

Я подумываю о замене сельдерея на малину.В настоящее время у нас есть кластер, в который отправляются различные задания, каждое из которых генерирует несколько задач, которые выполняются параллельно.У сельдерея есть функция убийцы, команда «отменить»: я могу убить все задачи данного задания, не мешая другим работам, которые выполняются одновременно.Как я могу сделать это с DASK?Я только нахожу ссылки, говорящие, что это невозможно, но для нас это будет катастрофой.Поэтому не нужно заставлять закрывать весь кластер, когда расчеты становятся мошенническими, что приводит к гибели заданий других пользователей.

1 Ответ

0 голосов
/ 30 сентября 2018

Вы можете отменить задачи, используя команду Client.cancel.

Если они еще не начались, то они не запустятся, однако, если они уже где-то запущены в потоке, тогда Python не сможет ничего сделать, чтобы остановить их, кроме как уничтожитьпроцесс.

...