最佳答案
是的,您正在寻找的功能恰当地命名为等待和进步.
from dask.distributed import wait,progress
>>> progress(x)
[XXXXXXX................] 5.2 seconds
如果您在IPython笔记本中,那么进度也是非阻塞的并使用IPython小部件.如果您使用的是IPython控制台或直接的Python可执行文件,则进度会阻塞,并且在计算完成之前不会返回.
如果您不想要进度条,或者如果您在Jupyter笔记本中,那么您可能需要单独使用wait函数,该函数将阻塞直到计算完成.
wait(x)
http://distributed.readthedocs.io/en/latest/api.html#distributed.client.wait
http://distributed.readthedocs.io/en/latest/api.html#distributed.diagnostics.progress
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。