From 7a997765d08e2546b48a39a620b7fe0cf52e6f41 Mon Sep 17 00:00:00 2001 From: MattWellie Date: Thu, 24 Oct 2024 11:13:02 +1000 Subject: [PATCH] lint --- cpg_workflows/jobs/vep.py | 9 ++------- 1 file changed, 2 insertions(+), 7 deletions(-) diff --git a/cpg_workflows/jobs/vep.py b/cpg_workflows/jobs/vep.py index 325aea9e8..ac1c8abf9 100644 --- a/cpg_workflows/jobs/vep.py +++ b/cpg_workflows/jobs/vep.py @@ -45,8 +45,7 @@ def add_vep_jobs( # read all input VCFs as resource groups input_vcf_resources: list[hb.ResourceGroup] = [ - b.read_input_group(**{'vcf.gz': str(path), 'vcf.gz.tbi': str(path) + '.tbi'}) - for path in input_vcfs + b.read_input_group(**{'vcf.gz': str(path), 'vcf.gz.tbi': str(path) + '.tbi'}) for path in input_vcfs ] result_parts_bucket = tmp_prefix / 'vep' / 'parts' @@ -82,11 +81,7 @@ def add_vep_jobs( gather_jobs = [j] elif scatter_count != 1: assert len(result_part_paths) == scatter_count - gather_jobs = gather_vcfs( - b=b, - input_vcfs=result_part_paths, - out_vcf_path=out_path, - ) + gather_jobs = gather_vcfs(b=b, input_vcfs=result_part_paths, out_vcf_path=out_path) else: print('no need to merge VEP results') gather_jobs = []