Skip to content

Commit

Permalink
cdacy fix
Browse files Browse the repository at this point in the history
  • Loading branch information
hanars committed Jul 26, 2023
1 parent 6159acf commit 49e8c03
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions hail_search/hail_search_query.py
Original file line number Diff line number Diff line change
Expand Up @@ -71,7 +71,7 @@ def annotation_fields(self):
r.sorted_transcript_consequences, hl.empty_array(r.sorted_transcript_consequences.dtype.element_type)
).map(lambda t: self._enum_field(
t, enums['sorted_transcript_consequences'], drop_fields=self.OMIT_TRANSCRIPT_FIELDS,
format=lambda value: value.rename({k: _to_camel_case(k) for k in value.keys()}),
format_value=lambda value: value.rename({k: _to_camel_case(k) for k in value.keys()}),
annotate=self._annotate_transcript,
)).group_by(lambda t: t.geneId),
}
Expand Down Expand Up @@ -100,7 +100,7 @@ def _annotate_transcript(cls, *args, **kwargs):
return {}

@staticmethod
def _enum_field(value, enum, ht_globals=None, annotate=None, format=None, drop_fields=None, **kwargs):
def _enum_field(value, enum, ht_globals=None, annotate=None, format_value=None, drop_fields=None, **kwargs):
annotations = {}
drop = [] + (drop_fields or [])
value_keys = value.keys()
Expand All @@ -121,8 +121,8 @@ def _enum_field(value, enum, ht_globals=None, annotate=None, format=None, drop_f
value = value.annotate(**annotations)
value = value.drop(*drop)

if format:
value = format(value)
if format_value:
value = format_value(value)

return value

Expand Down Expand Up @@ -321,7 +321,7 @@ class VariantHailTableQuery(BaseHailTableQuery):
'hgmd': {},
'screen': {
'response_key': 'screenRegionType',
'format': lambda value: value.region_types.first(),
'format_value': lambda value: value.region_types.first(),
},
}

Expand All @@ -331,7 +331,7 @@ def import_filtered_table(cls, *args, **kwargs):
return ht.key_by(**{VARIANT_KEY_FIELD: ht.variant_id})

@classmethod
def _annotate_transcript(cls, transcript, *args, **kwargs):
def _annotate_transcript(cls, transcript, enum, ht_globals):
return {'major_consequence': transcript.consequence_terms.first()}


Expand Down

0 comments on commit 49e8c03

Please sign in to comment.