Skip to content

Commit b85db51

Browse files
authored
Check for has_lookup_table (#777)
1 parent e4f2d5f commit b85db51

File tree

2 files changed

+19
-15
lines changed

2 files changed

+19
-15
lines changed

v03_pipeline/lib/tasks/update_variant_annotations_table_with_deleted_families.py

Lines changed: 10 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -20,14 +20,16 @@ def __init__(self, *args, **kwargs):
2020
super().__init__(*args, **kwargs)
2121
self.done = False
2222

23-
def requires(self) -> luigi.Task:
24-
return UpdateLookupTableWithDeletedFamiliesTask(
25-
dataset_type=self.dataset_type,
26-
sample_type=self.sample_type,
27-
reference_genome=self.reference_genome,
28-
project_guid=self.project_guid,
29-
family_guids=self.family_guids,
30-
)
23+
def requires(self) -> luigi.Task | None:
24+
if self.dataset_type.has_lookup_table:
25+
return UpdateLookupTableWithDeletedFamiliesTask(
26+
dataset_type=self.dataset_type,
27+
sample_type=self.sample_type,
28+
reference_genome=self.reference_genome,
29+
project_guid=self.project_guid,
30+
family_guids=self.family_guids,
31+
)
32+
return None
3133

3234
def complete(self) -> bool:
3335
if not self.dataset_type.has_lookup_table:

v03_pipeline/lib/tasks/update_variant_annotations_table_with_deleted_project.py

Lines changed: 9 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -15,13 +15,15 @@ class UpdateVariantAnnotationsTableWithDeletedProjectTask(
1515
):
1616
project_guid = luigi.Parameter()
1717

18-
def requires(self) -> luigi.Task:
19-
return UpdateLookupTableWithDeletedProjectTask(
20-
dataset_type=self.dataset_type,
21-
sample_type=self.sample_type,
22-
reference_genome=self.reference_genome,
23-
project_guid=self.project_guid,
24-
)
18+
def requires(self) -> luigi.Task | None:
19+
if self.dataset_type.has_lookup_table:
20+
return UpdateLookupTableWithDeletedProjectTask(
21+
dataset_type=self.dataset_type,
22+
sample_type=self.sample_type,
23+
reference_genome=self.reference_genome,
24+
project_guid=self.project_guid,
25+
)
26+
return None
2527

2628
def complete(self) -> bool:
2729
return super().complete() and hl.eval(

0 commit comments

Comments
 (0)