Try mp.context.ForkProcess in test_priority_pools()

9 months ago · cbc9015b71
parent b2047f5590
commit cbc9015b71
1 changed files with 1 additions and 1 deletions
--- a/tests/test_priority_pool.py
+++ b/tests/test_priority_pool.py
@ -51,7 +51,7 @@ def test_priority_pools():
    runtime = Runtime({str(i): DummyBackend([pool]) for i, pool in enumerate(pools)}, prefetch_batches=0)
    runtime.start()

-    proc = mp.Process(target=_process_tasks, args=(pools, results_valid))
+    proc = mp.context.ForkProcess(target=_process_tasks, args=(pools, results_valid))
    proc.start()
    proc.join()
    assert results_valid.is_set()