我已经建立了一个具有8个工作人员的本地集群。现在,我希望将特定任务提交给特定工作者。如何在本地群集中执行此操作?
https://distributed.dask.org/en/latest/api.html#distributed.Client.run
[使用worker =关键字参数限制对特定工人的计算。
>>> c.run(os.getpid, workers=['192.168.0.100:9000',
... '192.168.0.101:9000']) # doctest: +SKIP
{'192.168.0.100:9000': 1234,
'192.168.0.101:9000': 4321}
您也可以使用resources
执行此操作:https://distributed.dask.org/en/latest/resources.html#example