Bug fix

crpellegrino · Oct 3, 2024 · 396ec6e · 396ec6e
1 parent 0676c63
commit 396ec6e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/custom_code/scripts/sync_databases.py b/custom_code/scripts/sync_databases.py
@@ -342,10 +342,10 @@ def update_spec(action, db_address=_SNEX2_DB):
                             snex2_id = value.get('snex2_id', '')
                             spec = db_session.query(Datum).filter(and_(Datum.data_type=='spectroscopy', Datum.id==snex2_id)).first()
                             if not spec.data_product_id:
-                                spec.delete()
+                                db_session.delete(spec)
                             else: # Delete the associated DataProduct with the spectrum
                                 data_product_id = spec.data_product_id
-                                spec.delete()
+                                db_session.delete(spec)
                                 db_session.query(Data_Product).filter(Data_Product.id == data_product_id).delete()
 
                             break