from IPython.parallel import Client
A Client.load_balanced_view
is used to get the object used for working with load balanced tasks.
rc = Client()
v = rc.load_balanced_view()
Set the variable d
on all engines:
rc[:]['d'] = 30
Define a function that will be our task:
def task(a):
return a, 10*d, a*10*d
Run the task once:
ar = v.apply(task, 5)
Print the results:
print "a, b, c: ", ar.get()
a, b, c: [5, 300, 1500]