File tree Expand file tree Collapse file tree 2 files changed +9
-1
lines changed
Expand file tree Collapse file tree 2 files changed +9
-1
lines changed Original file line number Diff line number Diff line change @@ -75,6 +75,9 @@ def put_allele_expressions(
7575 url ,
7676 )
7777 if response .status_code == HTTPStatus .UNPROCESSABLE_ENTITY :
78+ _logger .debug (
79+ "Translation failed for variant expression '%s'" , expression
80+ )
7881 results .append (None )
7982 else :
8083 raise AnyVarClientError from e
Original file line number Diff line number Diff line change @@ -33,7 +33,7 @@ def _yield_expression_af_batches(
3333 for record in vcf :
3434 for i , alt in enumerate (record .alts or []):
3535 if record .ref is None or "*" in record .ref or "*" in alt :
36- _logger .warning ("Skipping missing allele at %s" , record )
36+ _logger .info ("Skipping missing allele at %s" , record )
3737 continue
3838 expression = f"{ record .chrom } -{ record .pos } -{ record .ref } -{ alt } "
3939 af = AfData (
@@ -45,10 +45,12 @@ def _yield_expression_af_batches(
4545 )
4646 batch .append ((expression , af ))
4747 if len (batch ) >= batch_size :
48+ _logger .debug ("Yielding next batch" )
4849 yield batch
4950 batch = []
5051 if batch :
5152 yield batch
53+ _logger .debug ("Expression/AF generator exhausted" )
5254
5355
5456def ingest_vcf (
@@ -80,3 +82,6 @@ def ingest_vcf(
8082 if variant_id is None :
8183 continue
8284 # make call to object store method for putting CAF here
85+ # presumably build the CAF object here + call the insert method with it
86+ # may need to alter zip() if the insert method expects a full variation
87+ # instead of just the ID
You can’t perform that action at this time.
0 commit comments