Dask工作者持久变量

Question

有没有一种方式与dask有一个变量，可以从一个任务检索到另一个。我的意思是一个变量，我可以在worker中锁定，然后在执行另一个任务时在同一个worker中检索。

Answer 1

工作人员本身只是Python进程，所以你可以用globals()做一些技巧。

但是，排放值并在任务之间传递值可能更清晰。 Dask保留重新运行功能并在不同机器上运行它们的权利，因此根据全球状态或特定于工作人员的状态，很容易使您陷入困境。