При выполнении приведенного ниже кода я ожидаю, что работники закроются как при успешном, так и при неудачном выполнении задачи:
res = client.submit(task, allow_other_workers=False, workers=set(workers))
try:
return res.result()
finally:
client.retire_workers(workers)
Но рабочие закрываются только в случае сбоя задачи или нажатия Ctrl + C (обычно это работает только при исключении). У вас есть идеи, что не так или лучше открыть вопрос? Спасибо.