任务工作者持久变量

Question

dask 有没有办法让一个变量可以从一个任务检索到另一个任务。我的意思是一个变量，我可以锁定在工作人员中，然后在我执行另一个任务时在同一个工作人员中检索。

Answer 1

worker 本身只是 Python 个进程，所以你可以用 globals() 来做一些技巧。

但是，发出值并在任务之间传递这些值可能更简洁。 Dask 保留重新运行 功能的权利，并且 运行 它们在不同的机器上，因此依赖于全局状态或特定于工人的状态很容易让你陷入麻烦。