Skip to content

Commit d9f9260

Browse files
Update src/acquisition/covidcast/database.py
Co-authored-by: george <george.haff@gmail.com>
1 parent f0e60f0 commit d9f9260

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

src/acquisition/covidcast/database.py

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -583,11 +583,14 @@ def compute_coverage_crossref(self):
583583
'''
584584

585585
self._connection.start_transaction()
586+
586587
self._cursor.execute(coverage_crossref_delete_sql)
587-
logger.info(f"coverage_crossref_delete_sql:{self._cursor.rowcount}")
588+
logger.info("coverage_crossref_delete", rows=self._cursor.rowcount)
588589

589590
self._cursor.execute(coverage_crossref_update_sql)
590-
logger.info(f"coverage_crossref_update_sql:{self._cursor.rowcount}")
591+
logger.info("coverage_crossref_update", rows=self._cursor.rowcount)
592+
591593
self.commit()
594+
logger.info("coverage_crossref committed")
592595

593596
return self._cursor.rowcount

0 commit comments

Comments
 (0)