python - Dask worker 持久变量

Question

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

Answer 1

工作人员本身只是 Python 进程，因此您可以使用globals().

但是，发出值并在任务之间传递这些值可能更干净。Dask 保留重新运行函数并在不同机器上运行它们的权利，因此根据全局状态或特定于工作人员的状态很容易让您陷入困境。