diff --git a/scripts/importer/data_importer/raw_data_importer.py b/scripts/importer/data_importer/raw_data_importer.py
index 1f8d07393..5d3115f65 100644
--- 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):