Я хочу принудительно уничтожить все процессы dask-worker, связанные с моим dask.distributed планировщиком. Я НЕ запускаю кластер локально, это распределенный кластер.
Я пробовал следующее:
workers = scheduler.workers_to_close(n=num_workers)
scheduler.retire_workers(workers=workers,close_workers=True,remove=True)
Здесь num_workers известно заранее.
Тем не менее, это не похоже на работу. Иногда никого не убивают, а иногда убивают только одного работника. Я делаю это неправильно? Есть ли лучший / правильный способ сделать это?