only one samplesheetToList

Author: maxulysse

subworkflows/local/utils_nfcore_rnaseq_pipeline/main.nf

@@ -12,7 +12,6 @@ import groovy.json.JsonSlurper
 
 include { UTILS_NFSCHEMA_PLUGIN     } from '../../nf-core/utils_nfschema_plugin'
 include { paramsSummaryMap          } from 'plugin/nf-schema'
-include { samplesheetToList         } from 'plugin/nf-schema'
 include { completionEmail           } from '../../nf-core/utils_nfcore_pipeline'
 include { completionSummary         } from '../../nf-core/utils_nfcore_pipeline'
 include { imNotification            } from '../../nf-core/utils_nfcore_pipeline'
@@ -73,28 +72,7 @@ workflow PIPELINE_INITIALISATION {
     //
     validateInputParameters()
 
-    //
-    // Create channel from input file provided through params.input
-    //
-
-    Channel
-        .fromList(samplesheetToList(params.input, "${projectDir}/assets/schema_input.json"))
-        .map {
-            meta, fastq_1, fastq_2 ->
-                if (!fastq_2) {
-                    return [ meta.id, meta + [ single_end:true ], [ fastq_1 ] ]
-                } else {
-                    return [ meta.id, meta + [ single_end:false ], [ fastq_1, fastq_2 ] ]
-                }
-        }
-        .groupTuple()
-        .map {
-            checkSamplesAfterGrouping(it)
-        }
-        .set{ ch_samplesheet }
-
     emit:
-    samplesheet = ch_samplesheet
     versions    = ch_versions
 }
 

workflows/rnaseq/main.nf

@@ -121,10 +121,10 @@ workflow RNASEQ {
                 }
         }
         .groupTuple()
-        .map {
-            checkSamplesAfterGrouping(it)
+        .map { samplesheet ->
+            checkSamplesAfterGrouping(samplesheet)
         }
-        .set{ ch_fastq }
+        .set { ch_fastq }
 
     //
     // Run RNA-seq FASTQ preprocessing subworkflow