|
@@ -54,7 +54,7 @@ class TestProcessing(BaseTest):
|
54
|
54
|
results = process_manager.make_them_work(data)
|
55
|
55
|
process_manager.terminate()
|
56
|
56
|
|
57
|
|
- assert sum(results) == 39600
|
|
57
|
+ assert sum(results) == 4950 * available_cores
|
58
|
58
|
|
59
|
59
|
@pytest.mark.timeout(10)
|
60
|
60
|
def test_non_parallel_jobs_with_scalar(self):
|
|
@@ -90,7 +90,7 @@ class TestProcessing(BaseTest):
|
90
|
90
|
for result_object in results:
|
91
|
91
|
final_result += result_object.value
|
92
|
92
|
|
93
|
|
- assert final_result == 39600
|
|
93
|
+ assert final_result == 4950 * available_cores
|
94
|
94
|
|
95
|
95
|
@pytest.mark.timeout(10)
|
96
|
96
|
def test_shared_memory_with_shared_manager(self):
|