From 078dcead01daf84b2defb5eed9bc4081045fb452 Mon Sep 17 00:00:00 2001 From: Aaron Steers Date: Wed, 27 Mar 2024 16:09:38 -0700 Subject: [PATCH] add explicit arg name to log_records_read() --- airbyte/sources/base.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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,