python - 从 Dask 任务流到完成的访问时间

Question

我正在使用 Dask Futures 来加速 python 中的蒙特卡洛过程，并希望通过向用户显示“剩余时间”功能来改进代码。我的想法是以某种方式从期货执行的先前完成的任务中获取完成时间，以估计此时间剩余价值。我看到这个时间信息显示在 dask 调度程序 GUI 中，但是有没有办法在 python 代码中获取它以便我可以使用它？对此的任何反馈将不胜感激。谢谢你。

标签： pythontimedaskdask-distributed

Answer 1

如果您的进程有一个本地调度程序（如果您使用 LocalCluster at ，这通常是这种情况client.cluster.scheduler），那么您可能需要查看该.total_occupancy属性。如果您想了解更多细节，请查看.task_groups