Distributed hello world¶

Originally by Ken Kinder (ken at kenkinder dom com)

In [1]:

from IPython.parallel import Client

In [2]:

rc = Client()
view = rc.load_balanced_view()

In [3]:

def sleep_and_echo(t, msg):
    import time
    time.sleep(t)
    return msg

In [4]:

world = view.apply_async(sleep_and_echo, 3, 'World!')
hello = view.apply_async(sleep_and_echo, 2, 'Hello')

In [6]:

print "Submitted tasks:", hello.msg_ids + world.msg_ids
print hello.get(), world.get()

Submitted tasks: ['04670c2d-b2fd-4b6b-a5ac-dee15e533683', 'fc802284-507b-4c29-a526-67396e17718c']
Hello World!

In [ ]: