From c3ba0eefbfa0e3fe0a7b9868247dee9ff7f870ec Mon Sep 17 00:00:00 2001
From: Bertache <samir.bertache@etu.uca.fr>
Date: Thu, 3 Apr 2025 14:27:03 +0200
Subject: [PATCH] Fixing num_processes
---
microsplit/split.py | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/microsplit/split.py b/microsplit/split.py
index dbfeb78..572953e 100644
--- a/microsplit/split.py
+++ b/microsplit/split.py
@@ -189,7 +189,7 @@ def cut(args, logging):
input_queue = Queue()
output_queue = Queue()
- read_processes, write_processes, compute_processes = partitionning(num_threads)
+ write_processes, compute_processes = partitionning(num_threads)
# communicate(write_processes=write_processes, compute_processes=compute_processes)
manager = ProcessManager()
@@ -199,13 +199,13 @@ def cut(args, logging):
try:
# Start worker processes
- manager.start_worker(target=read_bam_pair, args=(bam_for_file, bam_rev_file, input_queue, read_processes))
+ manager.start_worker(target=read_bam_pair, args=(bam_for_file, bam_rev_file, input_queue, compute_processes))
# Process for processing items
[
manager.start_worker(target=process_items, args=(input_queue, output_queue, seed_size, len_add)) for _ in range(compute_processes)
]
# Process for writing pairs
- manager.start_worker(target=write_fastq_pair, args=(output_queue, output_forward, output_reverse, write_processes))
+ manager.start_worker(target=write_fastq_pair, args=(output_queue, output_forward, output_reverse, compute_processes, write_processes))
# Monitor processes
while manager.running():
if not manager.check_processes():
--
GitLab