Skip to content

Commit

Permalink
add if statement for bcl_convert with multiome
Browse files Browse the repository at this point in the history
  • Loading branch information
deeptha-broad committed May 14, 2024
1 parent 02e51de commit 6d16edf
Showing 1 changed file with 13 additions and 12 deletions.
25 changes: 13 additions & 12 deletions src/sc_pipeline.py
Original file line number Diff line number Diff line change
Expand Up @@ -243,18 +243,19 @@ def process_multiome():

sample_tracking = sample_tracking[sample_sheet_columns]

# FASTQ generation can be parallelized
with concurrent.futures.ThreadPoolExecutor(max_workers=max_parallel_threads) as executor:
sub_methods = set(sample_tracking['sub_method'])
futures = []
for m in sub_methods:
futures.append(executor.submit(process_bcl_convert, sample_tracking[sample_tracking.sub_method == m]))

for future in concurrent.futures.as_completed(futures):
try:
logging.info(future.result())
except Exception as e:
logging.error(e)
if "BCL_CONVERT" in steps_to_run:
# FASTQ generation can be parallelized
with concurrent.futures.ThreadPoolExecutor(max_workers=max_parallel_threads) as executor:
sub_methods = set(sample_tracking['sub_method'])
futures = []
for m in sub_methods:
futures.append(executor.submit(process_bcl_convert, sample_tracking[sample_tracking.sub_method == m]))

for future in concurrent.futures.as_completed(futures):
try:
logging.info(future.result())
except Exception as e:
logging.error(e)

# add path to fastq for each sample before running cellranger
get_run_id = lambda sample: os.path.basename(sample['seq_dir'])
Expand Down

0 comments on commit 6d16edf

Please sign in to comment.