中止长时间运行的 iPyParallel 任务

问题描述

我有一个内核很少的 iPyParallel 集群。我已经通过 apply_async() 向他们提交了不同的任务。它们中的大多数已完成,并且 AsyncResult.ready() 正确显示了状态。但是有一个很长的运行时间,我想在特定时间后从客户端代码中止/终止它。

ippCluster.outstanding 显示未完成的任务。

ippCluster.abort("5baf4b1e-c47a639daa7ca9db08a01d0b") 提示<Future at 0x1f296b70fc8 state=pending>

ippCluster.shutdown("all") 关闭所有“空闲”引擎,但直到运行的引擎。 但它也会关闭我想用于进一步计算的内核/引擎,所以这不是我想要的。

如果,即任务内部有一个无限循环,那么如何远程终止这个任务?

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)