检查哪些ObjectID是在ray中完成的

Rho*_*Phi 2 python parallel-processing ray

我在射线中有一些远​​程函数提交用于计算。在使用它们之前,ray.get我想首先检查它们是否已完成,以便在它们计算时我可以继续做其他事情。

我也真的在考虑维护一本具有这种结构的字典

{
  { 'JSON of parameters used in the calculation': OBJECTid},
   ...
}
Run Code Online (Sandbox Code Playgroud)

这样我就可以定期阅读这本字典并收集已完成的 OBJECTid。为此,我需要询问任务管理器以了解 OBJECTid 是否已完成。

在这个页面上我似乎看到了有趣的函数,例如ray.objects()函数。然而,这似乎在我的笔记本中不可用,尽管我看到那里列出了许多其他功能,例如 、ray.init()ray.shutdown()。列出的所有功能Inspect the Cluster State似乎都丢失了,也许我错过了一些重要的步骤(导入?)

Rho*_*Phi 5

事实证明这些ray.wait函数可以做到这一点。将超时设置为零是关键,否则会阻塞内核。

ready_ids, _remaining_ids = ray.wait([OBJECTid],timeout=0)
Run Code Online (Sandbox Code Playgroud)