Merge branch 'maxi297/bland_stream_instantiated_as_defaultstream' into maxi297/incremental_without_partition_router_as_defaultstream

Author: maxi297

airbyte_cdk/sources/declarative/concurrent_declarative_source.py

@@ -466,7 +466,7 @@ def _group_streams(
                     partition_generator = StreamSlicerPartitionGenerator(
                         DeclarativePartitionFactory(
                             stream_name=declarative_stream.name,
-                            schema_loader=declarative_stream._schema_loader,   # type: ignore  # We are accessing the private property but the public one is optional and we will remove this code soonish
+                            schema_loader=declarative_stream._schema_loader,  # type: ignore  # We are accessing the private property but the public one is optional and we will remove this code soonish
                             retriever=retriever,
                             message_repository=self.message_repository,
                             max_records_limit=self._limits.max_records if self._limits else None,

airbyte_cdk/sources/declarative/stream_slicers/declarative_partition_generator.py

@@ -86,7 +86,9 @@ def read(self) -> Iterable[Record]:
             global total_record_counter
             if total_record_counter >= self._max_records_limit:
                 return
-        for stream_data in self._retriever.read_records(self._schema_loader.get_json_schema(), self._stream_slice):
+        for stream_data in self._retriever.read_records(
+            self._schema_loader.get_json_schema(), self._stream_slice
+        ):
             if self._max_records_limit:
                 if total_record_counter >= self._max_records_limit:
                     break

unit_tests/connector_builder/test_connector_builder_handler.py

@@ -785,7 +785,11 @@ def test_config_update() -> None:
         "refresh_token": "a refresh token",
     }
     source = ConcurrentDeclarativeSource(
-        catalog=None, config=config, state=None, source_config=manifest, emit_connector_builder_messages=True,
+        catalog=None,
+        config=config,
+        state=None,
+        source_config=manifest,
+        emit_connector_builder_messages=True,
     )
 
     refresh_request_response = {