##// 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 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("ZeroDivisionError" in stderr, stderr)
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