|
|
@@ -10,10 +10,7 @@ use log::{debug, info};
|
|
|
use uuid::Uuid;
|
|
|
|
|
|
use crate::{
|
|
|
- collection::bam_stats::{QNameSet, WGSBamStats},
|
|
|
- commands::{LocalBatchRunner, LocalRunner, SbatchRunner, SlurmParams, SlurmRunner},
|
|
|
- config::Config,
|
|
|
- runners::Run,
|
|
|
+ collection::bam_stats::{QNameSet, WGSBamStats}, commands::{LocalBatchRunner, LocalRunner, SbatchRunner, SlurmParams, SlurmRunner}, config::Config, run, runners::Run
|
|
|
};
|
|
|
|
|
|
/// Wrapper around a `samtools index` invocation.
|
|
|
@@ -119,6 +116,7 @@ pub struct SamtoolsReheader {
|
|
|
/// Sample name to inject as `SM:<sample>` in all `@RG` lines.
|
|
|
pub sample: String,
|
|
|
slurm: bool,
|
|
|
+ config: Config,
|
|
|
}
|
|
|
|
|
|
impl super::Command for SamtoolsReheader {
|
|
|
@@ -172,6 +170,7 @@ impl SamtoolsReheader {
|
|
|
bam: bam.to_string(),
|
|
|
sample: sample.to_string(),
|
|
|
slurm: config.slurm_runner,
|
|
|
+ config: config.clone(),
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
@@ -179,7 +178,8 @@ impl SamtoolsReheader {
|
|
|
impl Run for SamtoolsReheader {
|
|
|
fn run(&mut self) -> anyhow::Result<()> {
|
|
|
if self.slurm {
|
|
|
- let _output = SlurmRunner::exec(self)?;
|
|
|
+ run!(&self.config, self)?;
|
|
|
+ // let _output = SlurmRunner::exec(self)?;
|
|
|
} else {
|
|
|
let _output = LocalRunner::exec(self)?;
|
|
|
}
|