我正在嘗試做類似的事情resource = MyResource()def fn(x): something = dosemthing(x, resource) return somethingclient = Client()results = client.map(fn, data)問題是它resource不可序列化并且構(gòu)建起來很昂貴。因此,我想在每個工人上構(gòu)造一次它,并可供fn.我該怎么做呢?或者有沒有其他方法可以讓resource所有工人都可以使用?
在 dask 分布式工作器上初始化狀態(tài)
拉風(fēng)的咖菲貓
2021-10-26 15:51:00