|
@@ -1538,7 +1538,7 @@ impl ExternalAnnotation {
|
|
|
unfound.par_sort();
|
|
unfound.par_sort();
|
|
|
unfound.dedup();
|
|
unfound.dedup();
|
|
|
|
|
|
|
|
- let header = vcf_header("/data/ref/hs1/chm13v2.0.dict")?.join("\n");
|
|
|
|
|
|
|
+ let header = vcf_header(&self.config.dict_file)?.join("\n");
|
|
|
|
|
|
|
|
let min_chunk_size = 1000;
|
|
let min_chunk_size = 1000;
|
|
|
let max_chunks = 150;
|
|
let max_chunks = 150;
|
|
@@ -1688,11 +1688,11 @@ impl ExternalAnnotation {
|
|
|
mut unfound: Vec<VcfVariant>,
|
|
mut unfound: Vec<VcfVariant>,
|
|
|
annotations: &Annotations,
|
|
annotations: &Annotations,
|
|
|
) -> anyhow::Result<()> {
|
|
) -> anyhow::Result<()> {
|
|
|
- unfound.par_sort();
|
|
|
|
|
|
|
+ unfound.par_sort_unstable();
|
|
|
unfound.dedup();
|
|
unfound.dedup();
|
|
|
info!("{} variants to annotate with VEP.", unfound.len());
|
|
info!("{} variants to annotate with VEP.", unfound.len());
|
|
|
|
|
|
|
|
- let header = vcf_header("/data/ref/hs1/chm13v2.0.dict")?.join("\n");
|
|
|
|
|
|
|
+ let header = vcf_header(&self.config.dict_file)?.join("\n");
|
|
|
|
|
|
|
|
let (sv, unfound): (Vec<VcfVariant>, Vec<VcfVariant>) =
|
|
let (sv, unfound): (Vec<VcfVariant>, Vec<VcfVariant>) =
|
|
|
unfound.into_iter().partition(|v| v.has_svtype());
|
|
unfound.into_iter().partition(|v| v.has_svtype());
|
|
@@ -1861,8 +1861,8 @@ fn process_vep_chunk(
|
|
|
let out_summary = format!("{out_vep}_summary.html");
|
|
let out_summary = format!("{out_vep}_summary.html");
|
|
|
let out_warnings = format!("{out_vep}_warnings.txt");
|
|
let out_warnings = format!("{out_vep}_warnings.txt");
|
|
|
|
|
|
|
|
- let mut vcf = File::create(&in_tmp)?; // If this fails, the error is propagated.
|
|
|
|
|
- writeln!(vcf, "{}", header)?; // If this fails, the error is propagated.
|
|
|
|
|
|
|
+ let mut vcf = File::create(&in_tmp)?;
|
|
|
|
|
+ writeln!(vcf, "{}", header)?;
|
|
|
|
|
|
|
|
for (i, row) in chunk.iter().enumerate() {
|
|
for (i, row) in chunk.iter().enumerate() {
|
|
|
writeln!(
|
|
writeln!(
|