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 23729b6 commit 320f543Copy full SHA for 320f543
tests/clickhouse-test
@@ -2956,11 +2956,14 @@ def do_run_tests(
2956
2957
processes = []
2958
for _ in range(jobs):
2959
+ tests_to_run = parallel_tests[:batch_size]
2960
+ del parallel_tests[:batch_size]
2961
+
2962
process = multiprocessing.Process(
2963
target=run_tests_process,
2964
args=(
2965
(
- parallel_tests,
2966
+ tests_to_run,
2967
batch_size,
2968
test_suite,
2969
True,
@@ -2974,6 +2977,9 @@ def do_run_tests(
2974
2977
processes.append(process)
2975
2978
process.start()
2976
2979
2980
+ # all of the tests are taken int account
2981
+ assert(len(parallel_tests) == 0)
2982
2983
while processes:
2984
sleep(0.1)
2985
sys.stdout.flush()
0 commit comments