From 246df862d91d146bb29d30f2fce43f293d5f345a Mon Sep 17 00:00:00 2001 From: Bertache <samir.bertache@etu.uca.fr> Date: Thu, 3 Apr 2025 14:25:01 +0200 Subject: [PATCH] Fix num_processes --- microsplit/auxiliary.py | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/microsplit/auxiliary.py b/microsplit/auxiliary.py index bcc48e7..48fa6a3 100644 --- a/microsplit/auxiliary.py +++ b/microsplit/auxiliary.py @@ -17,10 +17,9 @@ def partitionning(num_processes): """ Partition the number of threads for writing and fragmenting. """ - read_processes = max(int(num_processes / 3), 2) - write_processes = read_processes - compute_processes = max(num_processes - (write_processes * 2), 1) - return read_processes, write_processes, compute_processes + write_processes = num_processes // 4 + compute_processes = num_processes - (write_processes * 2) + return write_processes, compute_processes def check_data(data): for element in data[0]: -- GitLab