##// END OF EJS Templates
workaround Windows lack of fork in subprocess tests...
MinRK -
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("ZeroDivisionError" in stderr, stderr)
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