run poetry run ruff format

Author: lmossman

airbyte_cdk/sources/declarative/parsers/manifest_normalizer.py

@@ -164,7 +164,13 @@ def _replace_parent_streams_with_refs(self) -> None:
             if not retriever:
                 continue
             partition_router = retriever.get("partition_router")
-            routers = partition_router if isinstance(partition_router, list) else [partition_router] if partition_router else []
+            routers = (
+                partition_router
+                if isinstance(partition_router, list)
+                else [partition_router]
+                if partition_router
+                else []
+            )
             for router in routers:
                 if not isinstance(router, dict):
                     continue
@@ -177,7 +183,11 @@ def _replace_parent_streams_with_refs(self) -> None:
                     stream_ref = parent_config.get("stream")
                     # Only replace if it's a dict and matches any stream in the manifest
                     for other_idx, other_stream in enumerate(stream_copies):
-                        if stream_ref is not None and isinstance(stream_ref, dict) and stream_ref == other_stream:
+                        if (
+                            stream_ref is not None
+                            and isinstance(stream_ref, dict)
+                            and stream_ref == other_stream
+                        ):
                             parent_config["stream"] = {"$ref": f"#/streams/{other_idx}"}
                             break
 
@@ -186,17 +196,18 @@ def _clean_dangling_fields(self) -> None:
         Clean the manifest by removing unused definitions and schemas.
         This method removes any definitions or schemas that are not referenced by any $ref in the manifest.
         """
+
         def find_all_refs(obj: Dict[str, Any], refs: List[str]) -> None:
             """
             Recursively find all $ref paths in the object.
-            
+
             Args:
                 obj: The object to search through
                 refs: List to store found reference paths
             """
             if not isinstance(obj, dict):
                 return
-                
+
             for key, value in obj.items():
                 if key == "$ref" and isinstance(value, str):
                     # Remove the leading #/ from the ref path
@@ -211,7 +222,7 @@ def find_all_refs(obj: Dict[str, Any], refs: List[str]) -> None:
         def clean_section(section: Dict[str, Any], section_path: str) -> None:
             """
             Clean a section by removing unreferenced fields.
-            
+
             Args:
                 section: The section to clean
                 section_path: The path to this section in the manifest

unit_tests/sources/declarative/parsers/conftest.py

@@ -143,41 +143,31 @@ def manifest_with_multiple_url_base() -> Dict[str, Any]:
                 "type": "object",
                 "$schema": "http://json-schema.org/draft-07/schema#",
                 "additionalProperties": True,
-                "properties": {
-                    "a": 1
-                },
+                "properties": {"a": 1},
             },
             "B": {
                 "type": "object",
                 "$schema": "http://json-schema.org/draft-07/schema#",
                 "additionalProperties": True,
-                "properties": {
-                    "b": 2
-                },
+                "properties": {"b": 2},
             },
             "C": {
                 "type": "object",
                 "$schema": "http://json-schema.org/draft-07/schema#",
                 "additionalProperties": True,
-                "properties": {
-                    "c": 3
-                },
+                "properties": {"c": 3},
             },
             "D": {
                 "type": "object",
                 "$schema": "http://json-schema.org/draft-07/schema#",
                 "additionalProperties": True,
-                "properties": {
-                    "d": 4
-                },
+                "properties": {"d": 4},
             },
             "E": {
                 "type": "object",
                 "$schema": "http://json-schema.org/draft-07/schema#",
                 "additionalProperties": True,
-                "properties": {
-                    "e": 5
-                },
+                "properties": {"e": 5},
             },
         },
     }
@@ -212,9 +202,7 @@ def expected_manifest_with_multiple_url_base_normalized() -> Dict[str, Any]:
                         "type": "object",
                         "$schema": "http://json-schema.org/draft-07/schema#",
                         "additionalProperties": True,
-                        "properties": {
-                            "a": 1
-                        },
+                        "properties": {"a": 1},
                     },
                 },
             },
@@ -241,9 +229,7 @@ def expected_manifest_with_multiple_url_base_normalized() -> Dict[str, Any]:
                         "type": "object",
                         "$schema": "http://json-schema.org/draft-07/schema#",
                         "additionalProperties": True,
-                        "properties": {
-                            "b": 2
-                        },
+                        "properties": {"b": 2},
                     },
                 },
             },
@@ -270,9 +256,7 @@ def expected_manifest_with_multiple_url_base_normalized() -> Dict[str, Any]:
                         "type": "object",
                         "$schema": "http://json-schema.org/draft-07/schema#",
                         "additionalProperties": True,
-                        "properties": {
-                            "c": 3
-                        },
+                        "properties": {"c": 3},
                     },
                 },
             },
@@ -299,9 +283,7 @@ def expected_manifest_with_multiple_url_base_normalized() -> Dict[str, Any]:
                         "type": "object",
                         "$schema": "http://json-schema.org/draft-07/schema#",
                         "additionalProperties": True,
-                        "properties": {
-                            "d": 4
-                        },
+                        "properties": {"d": 4},
                     },
                 },
             },
@@ -328,10 +310,8 @@ def expected_manifest_with_multiple_url_base_normalized() -> Dict[str, Any]:
                         "type": "object",
                         "$schema": "http://json-schema.org/draft-07/schema#",
                         "additionalProperties": True,
-                        "properties": {
-                            "e": 5
-                        }
-                    }
+                        "properties": {"e": 5},
+                    },
                 },
             },
         ],