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