##// END OF EJS Templates
flush replies when entering an eventloop...
flush replies when entering an eventloop avoids possible hangs when the GUI eventloop prevents queued replies from being sent

File last commit:

r13997:51ac15e6
r15232:158d7616
Show More
task1.ipynb
140 lines | 2.6 KiB | text/plain | TextLexer

Simple task farming example

In [1]:
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.

In [2]:
rc = Client()
v = rc.load_balanced_view()

Set the variable d on all engines:

In [3]:
rc[:]['d'] = 30

Define a function that will be our task:

In [4]:
def task(a):
    return a, 10*d, a*10*d

Run the task once:

In [5]:
ar = v.apply(task, 5)

Print the results:

In [6]:
print("a, b, c: ", ar.get())
a, b, c:  [5, 300, 1500]
In [ ]: