ruff fix

Author: aaronsteers

airbyte_cdk/connector.py

@@ -8,8 +8,6 @@
 import os
 import pkgutil
 from abc import ABC, abstractmethod
-from email import message
-from io import StringIO
 from pathlib import Path
 from typing import Any, Generic, Mapping, Optional, Self, TypeVar
 
@@ -22,7 +20,6 @@
 )
 from airbyte_cdk.models.airbyte_protocol import AirbyteMessage, Type
 from airbyte_cdk.sources.message.repository import MessageRepository, PassthroughMessageRepository
-from airbyte_cdk.test.entrypoint_wrapper import EntrypointOutput
 from airbyte_cdk.utils.cli_arg_parse import ConnectorCLIArgs, parse_cli_args
 
 
@@ -33,6 +30,7 @@ def _load_optional_package_file(package: str, filename: str) -> Optional[bytes]:
     except FileNotFoundError:
         return None
 
+
 def _write_config(config: Mapping[str, Any], config_path: str) -> None:
     Path(config_path).write_text(json.dumps(config))
 

airbyte_cdk/utils/cli_arg_parse.py

@@ -1,7 +1,6 @@
 # Copyright (c) 2025 Airbyte, Inc., all rights reserved.
 """CLI Argument Parsing Utilities."""
 
-
 import argparse
 import json
 from collections.abc import MutableMapping

unit_tests/sources/file_based/test_scenarios.py

@@ -235,11 +235,13 @@ def spec(capsys: CaptureFixture[str], scenario: TestScenario[AbstractSource]) ->
 def check(
     capsys: CaptureFixture[str], tmp_path: PosixPath, scenario: TestScenario[AbstractSource]
 ) -> Dict[str, Any]:
-    scenario.source.launch_with_cli_args([
-        "check",
-        "--config",
-        make_file(tmp_path / "config.json", scenario.config),
-    ])
+    scenario.source.launch_with_cli_args(
+        [
+            "check",
+            "--config",
+            make_file(tmp_path / "config.json", scenario.config),
+        ]
+    )
     captured = capsys.readouterr()
     return _find_connection_status(captured.out.splitlines())