adapt clustering live input

genepi · Dec 4, 2024 · bdcefe8 · bdcefe8
1 parent fb9f862
commit bdcefe8
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/lib/processes/cluster_live.nf b/lib/processes/cluster_live.nf
@@ -22,7 +22,7 @@ process CLUSTER_LIVE {
         --minseqlength ${params.min_length} \
         --maxseqlength ${params.max_length} \
         --threads ${params.threads} \
-        --cluster_fast ${detected_umis_fastq_dir}/* \
+        --cluster_fast ${detected_umis_fastq_dir} \
         --clusterout_sort \
         --gapopen 0E/5I \
         --gapext 0E/2I \

diff --git a/lib/workflows/umi-pipeline-live.nf b/lib/workflows/umi-pipeline-live.nf
@@ -85,8 +85,9 @@ workflow UMI_PIPELINE_LIVE {
         DETECT_UMI_FASTQ( splt_reads_filtered, raw, umi_extract )
 
         channel
-            .watchPath( "${params.output}/*/${params.output_format}_umi/raw/*fastq" )
-            .map{ fastq -> tuple(fastq.parent.parent.parent.name, "target", fastq.parent) }
+            //.watchPath( "${params.output}/*/${params.output_format}_umi/raw/*fastq" )
+            .watchPath( "${params.output}/*/${params.output_format}_umi/raw/" )
+            .map{ fastq -> tuple(fastq.parent.parent.parent.name, "target", fastq) }
             .set{ cluster_ch }
 
         cluster_ch.view()