add explicit arg name to log_records_read()

airbytehq · Mar 27, 2024 · 078dcea · 078dcea
1 parent 204e8bf
commit 078dcea
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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,