# 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())