summaryrefslogtreecommitdiff
path: root/framework/profile.py
diff options
context:
space:
mode:
Diffstat (limited to 'framework/profile.py')
-rw-r--r--framework/profile.py5
1 files changed, 3 insertions, 2 deletions
diff --git a/framework/profile.py b/framework/profile.py
index ffc91e0a6..a6cac2cf0 100644
--- a/framework/profile.py
+++ b/framework/profile.py
@@ -597,7 +597,7 @@ def load_test_profile(filename, python=None):
'Did you specify the right file?'.format(filename))
-def run(profiles, logger, backend, concurrency):
+def run(profiles, logger, backend, concurrency, jobs):
"""Runs all tests using Thread pool.
When called this method will flatten out self.tests into self.test_list,
@@ -614,6 +614,7 @@ def run(profiles, logger, backend, concurrency):
profiles -- a list of Profile instances.
logger -- a log.LogManager instance.
backend -- a results.Backend derived instance.
+ jobs -- maximum number of concurrent jobs. Use os.cpu_count() by default
"""
chunksize = 1
@@ -670,7 +671,7 @@ def run(profiles, logger, backend, concurrency):
#
# The default value of pool is the number of virtual processor cores
single = multiprocessing.dummy.Pool(1)
- multi = multiprocessing.dummy.Pool()
+ multi = multiprocessing.dummy.Pool(jobs)
try:
for p in profiles: