Dask工作者持久變量

Question

有沒有一種方式與dask有一個變量，可以從一個任務檢索到另一個。我的意思是一個變量，我可以在worker中鎖定，然後在執行另一個任務時在同一個worker中檢索。

Answer 1

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

但是，排放值並在任務之間傳遞值可能更清晰。 Dask保留重新運行功能並在不同機器上運行它們的權利，因此根據全球狀態或特定於工作人員的狀態，很容易使您陷入困境。