We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e87f5ec commit 08a47b5Copy full SHA for 08a47b5
test/test_graphtik.py
@@ -323,11 +323,14 @@ def check_task_context():
323
)
324
iop = iter(pipe.ops)
325
326
- print(_exe_params)
+ print(_exe_params, os.cpu_count())
327
err = None
328
if _exe_params.proc and _exe_params.marshal:
329
err = Exception("^Error sending result")
330
- elif _exe_params.parallel:
+ elif _exe_params.parallel and _exe_params.marshal:
331
+ err = AssertionError("^Corrupted task-context")
332
+ elif _exe_params.parallel and not os.environ.get("TRAVIS"):
333
+ # Travis has low parallelism and error does not surface
334
err = AssertionError("^Corrupted task-context")
335
336
if err:
0 commit comments