Глобальный кластерный объект для дисп

Question

(1) Можно ли сделать кластерный объект глобальным для всех машин, чтобы после отправки задания это задание, в свою очередь, могло отправлять другие разнородные задания меньшего размера?

cluster = dispy.JobCluster(compute)

(2) Может ли функция "вычислить" отличаться при каждом вызове отправки?

Answer 1

(1) Я считаю, что вам нужно посмотреть на SharedCluster объект, с которым я не знаком.

(2) Вы можете создавать различные "функции" внутри compute использовать функцию if заявления и передача аргумента выбора compute:

def compute(param):

    if param == 'a':
        'Do something'
    if param == 'b':
        'Do something else'

cluster = dispy.JobCluster(compute)

for i in params:

    cluster.submit(i)