如何解决在不重新创建图形的情况下更改 dask 延迟输入
我对一些数据进行了一系列计算,我将这些数据建模为具有 dask 延迟的图形,并且运行良好,但是创建图形本身所需的时间(或相当的时间)比运行计算所需的时间要长。
我整天都在添加数据,所以希望能够在不重新创建图表的情况下更改输入,有没有办法做到这一点?
解决方法
这是一个高级主题,所以我将只提供一个有点hacky的解决方案:
import dask
from dask.multiprocessing import get
@dask.delayed()
def myfunc(x):
return x+1
nested = 0
for x in range(1,3):
nested = myfunc(x*nested,dask_key_name=f'{x}')
# 1*0 + 1 = 1 -> 2*1 + 1 = 3
print(nested.compute())
dag_modified = nested.dask.to_dict()
dag_modified['1'] = modified_dag['1'][0],2
# 1*2 + 1 = 3 -> 2*3 + 1 = 7
print(get(dag_modified,'2'))
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。