diff --git a/airbyte-cdk/python/airbyte_cdk/sources/abstract_source.py b/airbyte-cdk/python/airbyte_cdk/sources/abstract_source.py index 8cc002cd2646..78199a181f92 100644 --- a/airbyte-cdk/python/airbyte_cdk/sources/abstract_source.py +++ b/airbyte-cdk/python/airbyte_cdk/sources/abstract_source.py @@ -145,15 +145,21 @@ def _read_stream( if internal_config.page_size and isinstance(stream_instance, HttpStream): logger.info(f"Setting page size for {stream_instance.name} to {internal_config.page_size}") stream_instance.page_size = internal_config.page_size - logger.debug( - f"Syncing stream: {configured_stream.stream.name}", + f"Syncing configured stream: {configured_stream.stream.name}", extra={ "sync_mode": configured_stream.sync_mode, "primary_key": configured_stream.primary_key, "cursor_field": configured_stream.cursor_field, }, ) + logger.debug( + f"Syncing stream instance: {stream_instance.name}", + extra={ + "primary_key": stream_instance.primary_key, + "cursor_field": stream_instance.cursor_field, + }, + ) use_incremental = configured_stream.sync_mode == SyncMode.incremental and stream_instance.supports_incremental if use_incremental: