apply additional autofixes

airbyte_cdk/destinations/vector_db_based/document_processor.py

@@ -161,9 +161,7 @@ def process(self, record: AirbyteRecordMessage) -> tuple[list[Chunk], str | None
             )
             for chunk_document in self._split_document(doc)
         ]
-        id_to_delete = (
-            doc.metadata.get(METADATA_RECORD_ID_FIELD, None)
-        )
+        id_to_delete = doc.metadata.get(METADATA_RECORD_ID_FIELD, None)
         return chunks, id_to_delete
 
     def _generate_document(self, record: AirbyteRecordMessage) -> Document | None:

airbyte_cdk/sources/concurrent_source/concurrent_read_processor.py

@@ -213,8 +213,7 @@ def is_done(self) -> bool:
         3. All partitions for all streams are closed
         """
         is_done = all(
-            self._is_stream_done(stream_name)
-            for stream_name in self._stream_name_to_instance
+            self._is_stream_done(stream_name) for stream_name in self._stream_name_to_instance
         )
         if is_done and self._exceptions_per_stream_name:
             error_message = generate_failed_streams_error_message(self._exceptions_per_stream_name)

airbyte_cdk/sources/declarative/requesters/error_handlers/composite_error_handler.py

@@ -72,9 +72,10 @@ def interpret_response(
             if matched_error_resolution.response_action == ResponseAction.SUCCESS:
                 return matched_error_resolution
 
-            if (
-                matched_error_resolution.response_action in {ResponseAction.RETRY, ResponseAction.IGNORE}
-            ):
+            if matched_error_resolution.response_action in {
+                ResponseAction.RETRY,
+                ResponseAction.IGNORE,
+            }:
                 return matched_error_resolution
         if matched_error_resolution:
             return matched_error_resolution

airbyte_cdk/sources/streams/call_rate.py

@@ -23,6 +23,7 @@
 # prevents mypy from complaining about missing session attributes in LimiterMixin
 if TYPE_CHECKING:
     from collections.abc import Mapping
+
     MIXIN_BASE = requests.Session
 else:
     MIXIN_BASE = object

airbyte_cdk/test/catalog_builder.py

@@ -78,5 +78,5 @@ def with_stream(
 
     def build(self) -> ConfiguredAirbyteCatalog:
         return ConfiguredAirbyteCatalog(
-            streams=[builder.build() for builder in self._streams]
+            streams=[builder.build() for builder in self._streams],
         )