Update src/acquisition/covidcast/database.py

Co-authored-by: george <[email protected]>
cmu-delphi · Feb 1, 2025 · d9f9260 · d9f9260
1 parent f0e60f0
commit d9f9260
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/src/acquisition/covidcast/database.py b/src/acquisition/covidcast/database.py
@@ -583,11 +583,14 @@ def compute_coverage_crossref(self):
     '''
 
     self._connection.start_transaction()
+
     self._cursor.execute(coverage_crossref_delete_sql)
-    logger.info(f"coverage_crossref_delete_sql:{self._cursor.rowcount}")
+    logger.info("coverage_crossref_delete", rows=self._cursor.rowcount)
 
     self._cursor.execute(coverage_crossref_update_sql)
-    logger.info(f"coverage_crossref_update_sql:{self._cursor.rowcount}")
+    logger.info("coverage_crossref_update", rows=self._cursor.rowcount)
+
     self.commit()
+    logger.info("coverage_crossref committed")
 
     return self._cursor.rowcount