test_contexts.py
43 lines
| 1.0 KiB
| text/x-python
|
PythonLexer
Fernando Perez
|
r1706 | #from __future__ import with_statement | ||
# XXX This file is currently disabled to preserve 2.4 compatibility. | ||||
Fernando Perez
|
r1435 | |||
Fernando Perez
|
r1406 | #def test_simple(): | ||
if 0: | ||||
# XXX - for now, we need a running cluster to be started separately. The | ||||
# daemon work is almost finished, and will make much of this unnecessary. | ||||
from IPython.kernel import client | ||||
mec = client.MultiEngineClient(('127.0.0.1',10105)) | ||||
try: | ||||
mec.get_ids() | ||||
except ConnectionRefusedError: | ||||
import os, time | ||||
os.system('ipcluster -n 2 &') | ||||
time.sleep(2) | ||||
mec = client.MultiEngineClient(('127.0.0.1',10105)) | ||||
mec.block = False | ||||
import itertools | ||||
c = itertools.count() | ||||
parallel = RemoteMultiEngine(mec) | ||||
mec.pushAll() | ||||
Fernando Perez
|
r1706 | ## with parallel as pr: | ||
## # A comment | ||||
## remote() # this means the code below only runs remotely | ||||
## print 'Hello remote world' | ||||
## x = range(10) | ||||
## # Comments are OK | ||||
## # Even misindented. | ||||
## y = x+1 | ||||
Fernando Perez
|
r1406 | |||
Fernando Perez
|
r1706 | ## with pfor('i',sequence) as pr: | ||
## print x[i] | ||||
Fernando Perez
|
r1406 | |||
print pr.x + pr.y | ||||