# 2 # # # Distributed hello world # # Originally by Ken Kinder (ken at kenkinder dom com) # from __future__ import print_function from IPython.parallel import Client # rc = Client() view = rc.load_balanced_view() # def sleep_and_echo(t, msg): import time time.sleep(t) return msg # world = view.apply_async(sleep_and_echo, 3, 'World!') hello = view.apply_async(sleep_and_echo, 2, 'Hello') # print("Submitted tasks:", hello.msg_ids, world.msg_ids) print(hello.get(), world.get())