Skip to content

Commit

Permalink
In demultiplexing, change (presumably misplaced) parameter "sections_…
Browse files Browse the repository at this point in the history
…file" to (presumably intended) parameter "refs_meta"
  • Loading branch information
matthewfallan committed Jan 1, 2024
1 parent 6b2e37f commit 6cbdc9b
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 7 deletions.
9 changes: 4 additions & 5 deletions src/seismicrna/demult/main.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@
opt_fastqx,
opt_out_dir,
opt_phred_enc,
opt_sections_file,
opt_refs_meta,
opt_temp_dir,
opt_keep_temp, )
from ..core.parallel import lock_temp_dir
Expand All @@ -37,8 +37,7 @@
opt_demulti_overwrite,
opt_temp_dir,
opt_keep_temp,
opt_sections_file,

opt_refs_meta,
]


Expand All @@ -51,7 +50,7 @@ def cli(*args, **kwargs):


@lock_temp_dir
def run(sections_file: str,
def run(refs_meta: str,
out_dir: str,
temp_dir: str,
fastqx: tuple[str, ...],
Expand All @@ -68,7 +67,7 @@ def run(sections_file: str,
""" Split multiplexed FASTQ files by their barcodes. """
fq_units = list(FastqUnit.from_paths(fastqx=list(map(Path, fastqx)),
phred_enc=phred_enc))
return [demultiplex_run(refs_file_csv=sections_file,
return [demultiplex_run(refs_file_csv=refs_meta,
overwrite=demulti_overwrite,
demulti_workspace=temp_dir,
report_folder=out_dir,
Expand Down
3 changes: 1 addition & 2 deletions src/seismicrna/wf/main.py
Original file line number Diff line number Diff line change
Expand Up @@ -89,7 +89,6 @@ def run(*,
fastqx: tuple[str, ...],
phred_enc: int,
# Demultiplexing options
section_file: str,
demulti_overwrite: bool,
demult_on: bool,
parallel_demultiplexing: bool,
Expand Down Expand Up @@ -197,7 +196,7 @@ def run(*,
if demult_on:
for dms, dmi, dmm in demultiplex_mod.run(
fasta=fasta,
sections_file=sections_file,
refs_meta=refs_meta,
out_dir=out_dir,
temp_dir=temp_dir,
demulti_overwrite=demulti_overwrite,
Expand Down

0 comments on commit 6cbdc9b

Please sign in to comment.