如何将任务分配给 dask 纱线集群中的特定工作人员

Question

dask.distributed 的这个问题的类似物可以在这里找到：如何在 Dask.Distributed 中将任务分配给特定的 worker

但同样的技术似乎不适用于 dask 的纱线簇。有没有办法在纱线簇的情况下做到这一点？即将任务分配给具有特定IP地址的特定节点中的特定工作线程？

Answer 1

我会回答我自己的问题。简而言之，我放置链接的帖子确实有效。但是，您必须确保分配给工作人员的方法具有不同的参数。否则，它将在同一容器上运行。