Skip to content
Snippets Groups Projects
Commit 025009a4 authored by Bertache's avatar Bertache
Browse files

Change caps name, and queue size

parent 3d3413b5
No related branches found
No related tags found
No related merge requests found
...@@ -11,7 +11,7 @@ from .bam import read_bam_pair ...@@ -11,7 +11,7 @@ from .bam import read_bam_pair
from .digest import build_restriction_index_from_records from .digest import build_restriction_index_from_records
from .processing import process_items from .processing import process_items
from .processmanager import ProcessManager from .processmanager import ProcessManager
from .restrictionsite import SearchInDataBase from .restrictionsite import search_in_database
from .stats import compact_and_save_counts from .stats import compact_and_save_counts
from .writer import write_bam_pair from .writer import write_bam_pair
...@@ -36,7 +36,7 @@ def categorize(args, logging): ...@@ -36,7 +36,7 @@ def categorize(args, logging):
len_max = args.len_max len_max = args.len_max
tolerance = int(args.tolerance) tolerance = int(args.tolerance)
ligation_site_list, restriction_site_list = SearchInDataBase(enzyme) ligation_site_list, restriction_site_list = search_in_database(enzyme)
if restriction_site_list is None: if restriction_site_list is None:
logging.error("Ligation site list is empty.") logging.error("Ligation site list is empty.")
sys.exit(0) sys.exit(0)
...@@ -52,16 +52,16 @@ def categorize(args, logging): ...@@ -52,16 +52,16 @@ def categorize(args, logging):
logging.error("BAM's file does not exist.") logging.error("BAM's file does not exist.")
sys.exit() sys.exit()
Input_Queue = Queue(1000)
Header_Queue = Queue() Header_Queue = Queue()
Output_Queue_Valide = Queue() Input_Queue = Queue(1000)
Output_Queue_Other = Queue() Output_Queue_Valide = Queue(1000)
Output_Queue_Other = Queue(1000)
Output_Queue_Del = Queue(1000)
Counts_Dang_Intra_Queue = Queue() Counts_Dang_Intra_Queue = Queue()
Counts_Biot_Intra_Queue = Queue() Counts_Biot_Intra_Queue = Queue()
Counts_Dang_Inter_Queue = Queue() Counts_Dang_Inter_Queue = Queue()
Counts_Biot_Inter_Queue = Queue() Counts_Biot_Inter_Queue = Queue()
Counts_Undigested_Site_Queue = Queue() Counts_Undigested_Site_Queue = Queue()
Output_Queue_Del = Queue()
write_processes, compute_processes, reading_process = partitionning( write_processes, compute_processes, reading_process = partitionning(
num_threads num_threads
) )
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment