Simple task farming example



In [1]:

    
from IPython.parallel import Client

A Client.load_balanced_view is used to get the object used for working with load balanced tasks.



In [2]:

    
rc = Client()
v = rc.load_balanced_view()

Set the variable d on all engines:



In [3]:

    
rc[:]['d'] = 30

Define a function that will be our task:



In [4]:

    
def task(a):
    return a, 10*d, a*10*d

Run the task once:



In [5]:

    
ar = v.apply(task, 5)

Print the results:



In [6]:

    
print "a, b, c: ", ar.get()









    



a, b, c:  [5, 300, 1500]



In [ ]: