Auto-fix lint and format issues

Author: octavia-squidington-iii

airbyte_cdk/sources/declarative/requesters/query_properties/properties_from_endpoint.py

@@ -33,12 +33,17 @@ def __post_init__(self, parameters: Mapping[str, Any]) -> None:
 
     def get_properties_from_endpoint(self, stream_slice: Optional[StreamSlice]) -> List[str]:
         if self._cached_properties is None:
-            self._cached_properties = list(map(self._get_property, self.retriever.read_records(records_schema={}, stream_slice=stream_slice)))  # type: ignore # extracted will be a MutableMapping, given input data structure
+            self._cached_properties = list(
+                map(
+                    self._get_property,
+                    self.retriever.read_records(records_schema={}, stream_slice=stream_slice),
+                )
+            )  # type: ignore # extracted will be a MutableMapping, given input data structure
         return self._cached_properties
 
     def _get_property(self, property_obj: Mapping[str, Any]) -> str:
         path = [
             node.eval(self.config) if not isinstance(node, str) else node
             for node in self._property_field_path
         ]
-        return str(dpath.get(property_obj, path, default=[]))  # type: ignore # extracted will be a MutableMapping, given input data structure
+        return str(dpath.get(property_obj, path, default=[]))  # type: ignore # extracted will be a MutableMapping, given input data structure

unit_tests/sources/declarative/requesters/query_properties/test_properties_from_endpoint.py

@@ -44,7 +44,9 @@ def test_get_properties_from_endpoint():
         parameters={},
     )
 
-    properties = properties_from_endpoint.get_properties_from_endpoint(stream_slice=StreamSlice(cursor_slice={}, partition={}))
+    properties = properties_from_endpoint.get_properties_from_endpoint(
+        stream_slice=StreamSlice(cursor_slice={}, partition={})
+    )
 
     assert len(properties) == 9
     assert properties == expected_properties
@@ -85,7 +87,9 @@ def test_get_properties_from_endpoint_with_multiple_field_paths():
         parameters={},
     )
 
-    properties = properties_from_endpoint.get_properties_from_endpoint(stream_slice=StreamSlice(cursor_slice={}, partition={}))
+    properties = properties_from_endpoint.get_properties_from_endpoint(
+        stream_slice=StreamSlice(cursor_slice={}, partition={})
+    )
 
     assert len(properties) == 9
     assert properties == expected_properties
@@ -127,7 +131,9 @@ def test_get_properties_from_endpoint_with_interpolation():
         parameters={},
     )
 
-    properties = properties_from_endpoint.get_properties_from_endpoint(stream_slice=StreamSlice(cursor_slice={}, partition={}))
+    properties = properties_from_endpoint.get_properties_from_endpoint(
+        stream_slice=StreamSlice(cursor_slice={}, partition={})
+    )
 
     assert len(properties) == 9
     assert properties == expected_properties
@@ -148,9 +154,15 @@ def test_given_multiple_calls_when_get_properties_from_endpoint_then_only_call_r
         parameters={},
     )
 
-    properties_from_endpoint.get_properties_from_endpoint(stream_slice=StreamSlice(cursor_slice={}, partition={}))
-    properties_from_endpoint.get_properties_from_endpoint(stream_slice=StreamSlice(cursor_slice={}, partition={}))
-    properties_from_endpoint.get_properties_from_endpoint(stream_slice=StreamSlice(cursor_slice={}, partition={}))
+    properties_from_endpoint.get_properties_from_endpoint(
+        stream_slice=StreamSlice(cursor_slice={}, partition={})
+    )
+    properties_from_endpoint.get_properties_from_endpoint(
+        stream_slice=StreamSlice(cursor_slice={}, partition={})
+    )
+    properties_from_endpoint.get_properties_from_endpoint(
+        stream_slice=StreamSlice(cursor_slice={}, partition={})
+    )
 
     assert retriever.read_records.call_count == 1
 
@@ -172,6 +184,8 @@ def test_given_value_is_int_when_get_properties_from_endpoint_then_return_str():
         parameters={},
     )
 
-    properties = properties_from_endpoint.get_properties_from_endpoint(stream_slice=StreamSlice(cursor_slice={}, partition={}))
+    properties = properties_from_endpoint.get_properties_from_endpoint(
+        stream_slice=StreamSlice(cursor_slice={}, partition={})
+    )
 
     assert properties == expected_properties

unit_tests/sources/declarative/requesters/query_properties/test_property_chunking.py

@@ -125,4 +125,4 @@ def test_given_single_property_chunk_when_get_request_property_chunks_then_alway
         )
     )
 
-    assert property_fields == ["rick", "chelsea", "victoria", "tim", "saxon", "lochlan", "piper"]
+    assert property_fields == ["rick", "chelsea", "victoria", "tim", "saxon", "lochlan", "piper"]