Skip to content
Snippets Groups Projects
Commit f963bb6e authored by bow's avatar bow
Browse files

Merge branch 'feature-disable_merging' into 'develop'

Addec config option to disable merging of countfiles



See merge request !392
parents fd9b7bea c7b0c415
No related branches found
No related tags found
No related merge requests found
...@@ -29,6 +29,7 @@ trait Measurement extends SummaryQScript with Reference { qscript: QScript => ...@@ -29,6 +29,7 @@ trait Measurement extends SummaryQScript with Reference { qscript: QScript =>
/** /**
* Method to add a bamFile to the pipeline * Method to add a bamFile to the pipeline
*
* @param id Unique id used for this bam file, most likely to be a sampleName * @param id Unique id used for this bam file, most likely to be a sampleName
* @param file Location of the bam file * @param file Location of the bam file
*/ */
...@@ -51,6 +52,8 @@ trait Measurement extends SummaryQScript with Reference { qscript: QScript => ...@@ -51,6 +52,8 @@ trait Measurement extends SummaryQScript with Reference { qscript: QScript =>
require(bamFiles.nonEmpty) require(bamFiles.nonEmpty)
} }
lazy val mergeCountFiles: Boolean = config("merge_count_files", default = true)
private var extraSummaryFiles: Map[String, File] = Map() private var extraSummaryFiles: Map[String, File] = Map()
def addMergeTableJob(countFiles: List[File], def addMergeTableJob(countFiles: List[File],
...@@ -58,18 +61,22 @@ trait Measurement extends SummaryQScript with Reference { qscript: QScript => ...@@ -58,18 +61,22 @@ trait Measurement extends SummaryQScript with Reference { qscript: QScript =>
name: String, name: String,
fileExtension: String, fileExtension: String,
args: MergeArgs = mergeArgs): Unit = { args: MergeArgs = mergeArgs): Unit = {
add(MergeTables(this, countFiles, outputFile, if (mergeCountFiles) {
args.idCols, args.valCol, args.numHeaderLines, args.fallback, fileExtension = Some(fileExtension))) add(MergeTables(this, countFiles, outputFile,
extraSummaryFiles += s"${name}_table" -> outputFile args.idCols, args.valCol, args.numHeaderLines, args.fallback, fileExtension = Some(fileExtension)))
extraSummaryFiles += s"${name}_table" -> outputFile
}
} }
def addHeatmapJob(countTable: File, outputFile: File, name: String, countType: Option[String] = None): Unit = { def addHeatmapJob(countTable: File, outputFile: File, name: String, countType: Option[String] = None): Unit = {
val job = new PlotHeatmap(qscript) if (mergeCountFiles) {
job.input = countTable val job = new PlotHeatmap(qscript)
job.output = outputFile job.input = countTable
job.countType = countType job.output = outputFile
add(job) job.countType = countType
extraSummaryFiles += s"${name}_heatmap" -> outputFile add(job)
extraSummaryFiles += s"${name}_heatmap" -> outputFile
}
} }
/** Must return a map with used settings for this pipeline */ /** Must return a map with used settings for this pipeline */
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment