# 2 # # # Simple task farming example # from __future__ import print_function 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())