Show More
@@ -133,10 +133,9 b' def test_subprocess_print():' | |||||
133 | flush_channels(km) |
|
133 | flush_channels(km) | |
134 | np = 5 |
|
134 | np = 5 | |
135 | code = '\n'.join([ |
|
135 | code = '\n'.join([ | |
|
136 | "from __future__ import print_function", | |||
136 | "import multiprocessing as mp", |
|
137 | "import multiprocessing as mp", | |
137 | "def f(x):", |
|
138 | "pool = [mp.Process(target=print, args=('hello', i,)) for i in range(%i)]" % np, | |
138 | " print('hello',x)", |
|
|||
139 | "pool = [mp.Process(target=f,args=(i,)) for i in range(%i)]" % np, |
|
|||
140 | "for p in pool: p.start()", |
|
139 | "for p in pool: p.start()", | |
141 | "for p in pool: p.join()" |
|
140 | "for p in pool: p.join()" | |
142 | ]) |
|
141 | ]) | |
@@ -163,9 +162,7 b' def test_subprocess_noprint():' | |||||
163 | np = 5 |
|
162 | np = 5 | |
164 | code = '\n'.join([ |
|
163 | code = '\n'.join([ | |
165 | "import multiprocessing as mp", |
|
164 | "import multiprocessing as mp", | |
166 | "def f(x):", |
|
165 | "pool = [mp.Process(target=range,args=(i,)) for i in range(%i)]" % np, | |
167 | " return x", |
|
|||
168 | "pool = [mp.Process(target=f,args=(i,)) for i in range(%i)]" % np, |
|
|||
169 | "for p in pool: p.start()", |
|
166 | "for p in pool: p.start()", | |
170 | "for p in pool: p.join()" |
|
167 | "for p in pool: p.join()" | |
171 | ]) |
|
168 | ]) | |
@@ -186,9 +183,7 b' def test_subprocess_error():' | |||||
186 |
|
183 | |||
187 | code = '\n'.join([ |
|
184 | code = '\n'.join([ | |
188 | "import multiprocessing as mp", |
|
185 | "import multiprocessing as mp", | |
189 | "def f():", |
|
186 | "p = mp.Process(target=int, args=('hi',))", | |
190 | " return 1/0", |
|
|||
191 | "p = mp.Process(target=f)", |
|
|||
192 | "p.start()", |
|
187 | "p.start()", | |
193 | "p.join()", |
|
188 | "p.join()", | |
194 | ]) |
|
189 | ]) | |
@@ -196,7 +191,7 b' def test_subprocess_error():' | |||||
196 | msg_id, content = execute(km=km, code=code) |
|
191 | msg_id, content = execute(km=km, code=code) | |
197 | stdout, stderr = assemble_output(iopub) |
|
192 | stdout, stderr = assemble_output(iopub) | |
198 | nt.assert_equal(stdout, '') |
|
193 | nt.assert_equal(stdout, '') | |
199 |
nt.assert_true(" |
|
194 | nt.assert_true("ValueError" in stderr, stderr) | |
200 |
|
195 | |||
201 | _check_mp_mode(km, expected=False) |
|
196 | _check_mp_mode(km, expected=False) | |
202 | _check_mp_mode(km, expected=False, stream="stderr") |
|
197 | _check_mp_mode(km, expected=False, stream="stderr") |
General Comments 0
You need to be logged in to leave comments.
Login now