Auto-fix lint and format issues

Author: octavia-squidington-iii

airbyte_cdk/sources/declarative/retrievers/file_uploader.py

@@ -2,11 +2,11 @@
 from pathlib import Path
 from typing import Optional
 
+from airbyte_cdk.models import AirbyteRecordMessageFileReference
 from airbyte_cdk.sources.declarative.extractors.record_extractor import RecordExtractor
 from airbyte_cdk.sources.declarative.partition_routers.substream_partition_router import (
     SafeResponse,
 )
-from airbyte_cdk.models import AirbyteRecordMessageFileReference
 from airbyte_cdk.sources.declarative.requesters import Requester
 from airbyte_cdk.sources.declarative.types import Record, StreamSlice
 from airbyte_cdk.sources.utils.files_directory import get_files_directory

airbyte_cdk/sources/utils/record_helper.py

@@ -9,8 +9,8 @@
     AirbyteLogMessage,
     AirbyteMessage,
     AirbyteRecordMessage,
-    AirbyteTraceMessage,
     AirbyteRecordMessageFileReference,
+    AirbyteTraceMessage,
 )
 from airbyte_cdk.models import Type as MessageType
 from airbyte_cdk.models.file_transfer_record_message import AirbyteFileTransferRecordMessage

unit_tests/sources/declarative/file/test_file_stream.py

@@ -50,9 +50,12 @@ def read(
         _source(catalog, config, state), config, catalog, state, expecting_exception
     )
 
+
 def discover(config_builder: ConfigBuilder, expecting_exception: bool = False) -> EntrypointOutput:
     config = config_builder.build()
-    return entrypoint_discover(_source(CatalogBuilder().build(), config), config, expecting_exception)
+    return entrypoint_discover(
+        _source(CatalogBuilder().build(), config), config, expecting_exception
+    )
 
 
 class FileStreamTest(TestCase):
@@ -99,5 +102,9 @@ def test_get_article_attachments(self) -> None:
     def test_discover_article_attachments(self) -> None:
         output = discover(self._config())
 
-        article_attachments_stream = next(filter(lambda stream: stream.name == "article_attachments", output.catalog.catalog.streams))
+        article_attachments_stream = next(
+            filter(
+                lambda stream: stream.name == "article_attachments", output.catalog.catalog.streams
+            )
+        )
         assert article_attachments_stream.is_file_based