如何解决在旧工人死亡后添加新工人时,如何重新提交 dask 工作来自以前死去的工人?
在旧工人死亡后添加新工人时,有没有办法重新提交工作(来自以前死去的工人)?
是否可以使用调度程序插件 distributed.diagnostics.plugin.SchedulerPlugin
来实现这一点?
解决方法
如果您使用的是 future
API,那么您可以使用 future
检查各个 .status
对象的状态属性并采取相应的措施。例如,如果 f
是一个 future 对象,那么我们可以要求调度程序根据以下条件重试其计算:
if f.status.isin(['error','cancelled','lost']):
f.retry()
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。