我有一个包含 40 个工作线程的计算网络,但我只需要在某些主机上执行计算。是否可以限制或重建网络以仅使用指定的工作人员?
最佳答案
是的,您可以使用 workers=
关键字为 client.submit、client.map、client.compute 或 client.persist 指定特定工作人员。
futures = client.map(func, args, workers=['worker-1', 'worker-2'])
参见http://distributed.readthedocs.io/en/latest/locality.html#user-control 更多选择
您还可以向工作人员注册 GPU 等资源,并将计算限制在这些资源上。请参阅http://distributed.readthedocs.io/en/latest/resources.html了解更多信息。
关于python - 是否可以在某些工作列表上运行 dask/分布式作业,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/42838988/