dataset_version in where

NBISweden · Apr 25, 2019 · f2a569f · f2a569f
1 parent 1bc2c5a
commit f2a569f
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/scripts/importer/data_importer/raw_data_importer.py b/scripts/importer/data_importer/raw_data_importer.py
@@ -264,7 +264,8 @@ def _insert_variants(self):
                     if fmt_alleles != fmt_alleles2:
                         query = db.Variant.update(orig_alt_alleles=fmt_alleles2).where((db.Variant.chrom==base['chrom']) &
                                                                                        (db.Variant.pos==base['pos']) &
-                                                                                       (db.Variant.ref==base['ref']))
+                                                                                       (db.Variant.ref==base['ref']) &
+                                                                                       (db.Variant.ref==base['dataset_version']))
                         query.execute()
 
                     for i, alt in enumerate(alt_alleles):