Skip to content
Snippets Groups Projects
Commit 246df862 authored by Bertache's avatar Bertache
Browse files

Fix num_processes

parent 85ae9db4
No related branches found
No related tags found
No related merge requests found
...@@ -17,10 +17,9 @@ def partitionning(num_processes): ...@@ -17,10 +17,9 @@ def partitionning(num_processes):
""" """
Partition the number of threads for writing and fragmenting. Partition the number of threads for writing and fragmenting.
""" """
read_processes = max(int(num_processes / 3), 2) write_processes = num_processes // 4
write_processes = read_processes compute_processes = num_processes - (write_processes * 2)
compute_processes = max(num_processes - (write_processes * 2), 1) return write_processes, compute_processes
return read_processes, write_processes, compute_processes
def check_data(data): def check_data(data):
for element in data[0]: for element in data[0]:
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment