Skip to content

Commit

Permalink
Read genomeSize from csv
Browse files Browse the repository at this point in the history
  • Loading branch information
veghp committed Sep 1, 2022
1 parent ade9b0d commit 6c7552e
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
3 changes: 2 additions & 1 deletion main.nf
Original file line number Diff line number Diff line change
Expand Up @@ -102,8 +102,9 @@ workflow assembly {

.map { row ->
def barcode = row['Barcode'] // a barcode is present only once -- no pooling
def length = row['Length'] // estimated length in kbp for canu genomeSize parameter
def fastq_path = file("${params.fastq_filtered_dir}/${barcode}.fastq")
return [barcode, fastq_path]
return [barcode, fastq_path, length]
}
.set { entries_assembly_ch }

Expand Down
5 changes: 2 additions & 3 deletions nextflow/sequeduct_review.nf
Original file line number Diff line number Diff line change
Expand Up @@ -216,13 +216,12 @@ process assembleOnly {
publishDir 'results/dir4_assembly/n1_de_novo_assembly', mode: 'copy'

input:
tuple val(barcode), path(fastq_path)
tuple val(barcode), path(fastq_path), val(length)
output:
tuple val(barcode), path(assembly_dir)
script:
assembly_dir = barcode + '_assembly'
// genomsize_param = 'genomeSize=' + seq_length + 'k'
genomsize_param = 'genomeSize=8k'
genomsize_param = 'genomeSize=' + length + 'k'
"""
canu -p $params.assembly_prefix -d $assembly_dir $genomsize_param -nanopore $fastq_path
"""
Expand Down

0 comments on commit 6c7552e

Please sign in to comment.