@@ -26,8 +26,12 @@ def test_dist_options(testdir):
|
|||||||
|
|
||||||
|
|
||||||
def test_auto_detect_cpus(testdir, monkeypatch):
|
def test_auto_detect_cpus(testdir, monkeypatch):
|
||||||
import multiprocessing
|
import os
|
||||||
monkeypatch.setattr(multiprocessing, 'cpu_count', lambda: 99)
|
if hasattr(os, 'cpu_count'):
|
||||||
|
monkeypatch.setattr(os, 'cpu_count', lambda: 99)
|
||||||
|
else:
|
||||||
|
import multiprocessing
|
||||||
|
monkeypatch.setattr(multiprocessing, 'cpu_count', lambda: 99)
|
||||||
|
|
||||||
config = testdir.parseconfigure("-n2")
|
config = testdir.parseconfigure("-n2")
|
||||||
assert config.getoption('numprocesses') == 2
|
assert config.getoption('numprocesses') == 2
|
||||||
|
|||||||
@@ -4,8 +4,15 @@ import pytest
|
|||||||
|
|
||||||
def parse_numprocesses(s):
|
def parse_numprocesses(s):
|
||||||
if s == 'auto':
|
if s == 'auto':
|
||||||
import multiprocessing
|
try:
|
||||||
return multiprocessing.cpu_count()
|
from os import cpu_count
|
||||||
|
except ImportError:
|
||||||
|
from multiprocessing import cpu_count
|
||||||
|
try:
|
||||||
|
n = cpu_count()
|
||||||
|
except NotImplementedError:
|
||||||
|
return 1
|
||||||
|
return n if n else 1
|
||||||
else:
|
else:
|
||||||
return int(s)
|
return int(s)
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user