mypy

Author: maxime.c

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

@@ -35,10 +35,10 @@ def get_properties_from_endpoint(self, stream_slice: Optional[StreamSlice]) -> L
         if self._cached_properties is None:
             self._cached_properties = list(
                 map(
-                    self._get_property,
+                    self._get_property,  # type: ignore # SimpleRetriever and AsyncRetriever only returns Record. Should we change the return type of Retriever.read_records?
                     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:

airbyte_cdk/sources/declarative/retrievers/simple_retriever.py

@@ -523,7 +523,6 @@ def read_records(
         """
         _slice = stream_slice or StreamSlice(partition={}, cursor_slice={})  # None-check
 
-        most_recent_record_from_slice = None
         record_generator = partial(
             self._parse_records,
             stream_slice=stream_slice,