##// END OF EJS Templates
fix typo in parallel_process
fix typo in parallel_process

File last commit:

r3666:a6a0636a
r4054:a9efa6ac
Show More
helloworld.py
19 lines | 424 B | text/x-python | PythonLexer
MinRK
update API after sagedays29...
r3664 """
A Distributed Hello world
Ken Kinder <ken@kenkinder.com>
"""
MinRK
move IPython.zmq.parallel to IPython.parallel
r3666 from IPython.parallel import Client
MinRK
update API after sagedays29...
r3664
MinRK
move IPython.zmq.parallel to IPython.parallel
r3666 rc = Client()
MinRK
update API after sagedays29...
r3664
def sleep_and_echo(t, msg):
import time
time.sleep(t)
return msg
view = rc.load_balanced_view()
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()