Как позволить всем работникам выполнять одно и то же задание в сумерках? - PullRequest
Новая
       6

Как позволить всем работникам выполнять одно и то же задание в сумерках?

0 голосов
/ 06 июля 2018

Я хочу, чтобы все работники выполняли одно и то же задание, например: 

from dask import distributed
from distributed import Client,LocalCluster
import dask
import socket


def writer(filename,data):
    with open(filename,'w') as f:
        f.writelines(data)

def get_ip(x):
    return socket.gethostname()
    #writer('/data/1.txt',a)
client = Client('192.168.123.1:8786')

A=client.submit(get_ip, 0,workers=['w1','w2'], pure=False)
print(client.ncores(),
        client.scheduler_info()
#       dask.config.get('distributed')
     )
A.result()

У меня есть 2 работника, но просто выведите 1 имя рабочего

1 Ответ

0 голосов
/ 06 июля 2018

Простой способ достичь желаемого - использовать метод Client.run 

client.run(socket.gethostname)

Запускает функцию для всех работников и возвращает все результаты. Он не использует обычную систему планирования задач, которая предназначена для целей, совершенно отличных от того, что вы хотите.

...