diff --git a/airbyte/sources/base.py b/airbyte/sources/base.py
index a6054186..5dea2d54 100644
--- a/airbyte/sources/base.py
+++ b/airbyte/sources/base.py
@@ -611,7 +611,7 @@ def _tally_records(
 
         for message in messages:
             yield message
-            progress.log_records_read(self._processed_records)
+            progress.log_records_read(new_total_count=self._processed_records)
 
     def _log_sync_start(
         self,