style: fix formatting issues

Co-Authored-By: Aaron <AJ> Steers <[email protected]>

Author: devin-ai-integration[bot]

airbyte_cdk/entrypoint.py

@@ -147,7 +147,11 @@ def run(self, parsed_args: argparse.Namespace) -> Iterable[str]:
                     ]
                     yield self.airbyte_message_to_string(message)
                 else:
-                    if cmd == "discover" and not parsed_args.config and not self.source.check_config_against_spec:
+                    if (
+                        cmd == "discover"
+                        and not parsed_args.config
+                        and not self.source.check_config_against_spec
+                    ):
                         empty_config = {}
                         yield from [
                             self.airbyte_message_to_string(queued_message)

unit_tests/sources/declarative/test_manifest_declarative_source_dynamic_schema.py

@@ -4,6 +4,7 @@
 from unittest.mock import MagicMock, patch
 
 import pytest
+
 from airbyte_cdk.models import AirbyteCatalog
 from airbyte_cdk.sources.declarative.manifest_declarative_source import ManifestDeclarativeSource
 from airbyte_cdk.sources.utils.schema_helpers import check_config_against_spec_or_exit
@@ -65,18 +66,20 @@ def test_check_config_against_spec_without_dynamic_schema_loader():
     source = ManifestDeclarativeSource(source_config=source_config)
 
 
-@patch("airbyte_cdk.sources.declarative.manifest_declarative_source.ManifestDeclarativeSource.streams")
+@patch(
+    "airbyte_cdk.sources.declarative.manifest_declarative_source.ManifestDeclarativeSource.streams"
+)
 def test_discover_with_dynamic_schema_loader_no_config(mock_streams):
     """Test that discovery works without config when DynamicSchemaLoader is used."""
     mock_stream = MagicMock()
     mock_stream.name = "test_dynamic_stream"
-    
+
     mock_airbyte_stream = MagicMock()
     type(mock_airbyte_stream).name = "test_dynamic_stream"
     mock_stream.as_airbyte_stream.return_value = mock_airbyte_stream
-    
+
     mock_streams.return_value = [mock_stream]
-    
+
     source_config = {
         "type": "DeclarativeSource",
         "check": {"type": "CheckStream"},
@@ -103,31 +106,33 @@ def test_discover_with_dynamic_schema_loader_no_config(mock_streams):
         ],
         "version": "0.1.0",
     }
-    
+
     source = ManifestDeclarativeSource(source_config=source_config)
-    
+
     assert source.check_config_against_spec is False
-    
+
     logger = MagicMock()
     catalog = source.discover(logger, {})
-    
+
     assert isinstance(catalog, AirbyteCatalog)
     assert len(catalog.streams) == 1
     assert catalog.streams[0].name == "test_dynamic_stream"
 
 
-@patch("airbyte_cdk.sources.declarative.manifest_declarative_source.ManifestDeclarativeSource.streams")
+@patch(
+    "airbyte_cdk.sources.declarative.manifest_declarative_source.ManifestDeclarativeSource.streams"
+)
 def test_discover_without_dynamic_schema_loader_no_config(mock_streams):
     """Test that discovery validates config when DynamicSchemaLoader is not used."""
     mock_stream = MagicMock()
     mock_stream.name = "test_static_stream"
-    
+
     mock_airbyte_stream = MagicMock()
     type(mock_airbyte_stream).name = "test_static_stream"
     mock_stream.as_airbyte_stream.return_value = mock_airbyte_stream
-    
+
     mock_streams.return_value = [mock_stream]
-    
+
     source_config = {
         "type": "DeclarativeSource",
         "check": {"type": "CheckStream"},
@@ -144,14 +149,14 @@ def test_discover_without_dynamic_schema_loader_no_config(mock_streams):
         ],
         "version": "0.1.0",
     }
-    
+
     source = ManifestDeclarativeSource(source_config=source_config)
-    
+
     assert source.check_config_against_spec is True
-    
+
     logger = MagicMock()
     catalog = source.discover(logger, {})
-    
+
     assert isinstance(catalog, AirbyteCatalog)
     assert len(catalog.streams) == 1
     assert catalog.streams[0].name == "test_static_stream"