fix: committing to db writing

alercebroker · Nov 3, 2023 · 6570e7d · 6570e7d
1 parent e6b12b7
commit 6570e7d
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/metadata_step/metadata_step/step.py b/metadata_step/metadata_step/step.py
@@ -27,6 +27,7 @@ def _format_detection(self, d: Dict, catalogs: Dict):
     def _write_metadata_into_db(self, result: List[Dict]):
         with self.db.session() as session:
             insert_metadata(session, result)
+            session.commit()
 
     # Output format: [{oid: OID, ss: SS_DATA, ...}]
     def execute(self, messages: List[Dict]):