Fix mypy

Author: lazebnyi

airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py

@@ -2534,6 +2534,10 @@ def create_parent_stream_config(
                 "The '*' wildcard in 'lazy_read_pointer' is not supported — only direct paths are allowed."
             )
 
+        model_lazy_read_pointer: List[Union[InterpolatedString, str]] = (
+            [x for x in model.lazy_read_pointer] if model.lazy_read_pointer else []
+        )
+
         return ParentStreamConfig(
             parent_key=model.parent_key,
             request_option=request_option,
@@ -2543,7 +2547,7 @@ def create_parent_stream_config(
             incremental_dependency=model.incremental_dependency or False,
             parameters=model.parameters or {},
             extra_fields=model.extra_fields,
-            lazy_read_pointer=model.lazy_read_pointer,
+            lazy_read_pointer=model_lazy_read_pointer,
         )
 
     @staticmethod
@@ -2748,18 +2752,28 @@ def create_simple_retriever(
         )
 
         if (
-            hasattr(model, "partition_router")
-            and model.partition_router
-            and model.partition_router.type == "SubstreamPartitionRouter"
+            model.partition_router
+            and model.partition_router.type == "SubstreamPartitionRouter"  # type: ignore[union-attr]  # 'model' is SimpleRetrieverModel
             and not bool(self._connector_state_manager.get_stream_state(name, None))
             and any(
                 parent_stream_config.lazy_read_pointer
-                for parent_stream_config in model.partition_router.parent_stream_configs
+                for parent_stream_config in model.partition_router.parent_stream_configs  # type: ignore[union-attr]  # partition_router type guaranteed by a condition earlier
             )
         ):
-            if incremental_sync and (incremental_sync.step or incremental_sync.cursor_granularity):
+            if incremental_sync:
+                if incremental_sync.type != "DatetimeBasedCursor":
+                    raise ValueError(
+                        f"LazySimpleRetriever only supports DatetimeBasedCursor. Found: {incremental_sync.type}."
+                    )
+
+                elif incremental_sync.step or incremental_sync.cursor_granularity:
+                    raise ValueError(
+                        f"Found more that one slice per parent. LazySimpleRetriever only supports single slice read for stream - {name}."
+                    )
+
+            if model.decoder and model.decoder.type != "JsonDecoder":
                 raise ValueError(
-                    f"Found more that one slice per parent. LazySimpleRetriever only supports single slice read for stream - {name}."
+                    f"LazySimpleRetriever only supports JsonDecoder. Found: {model.decoder.type}."
                 )
 
             return LazySimpleRetriever(

airbyte_cdk/sources/declarative/partition_routers/substream_partition_router.py

@@ -215,7 +215,7 @@ def stream_slices(self) -> Iterable[StreamSlice]:
                     if parent_stream_config.lazy_read_pointer:
                         extracted_extra_fields = {
                             "child_response": self._extract_child_response(
-                                parent_record, parent_stream_config.lazy_read_pointer
+                                parent_record, parent_stream_config.lazy_read_pointer  # type: ignore[arg-type]  # lazy_read_pointer type handeled in __post_init__ of parent_stream_config
                             ),
                             **extracted_extra_fields,
                         }
@@ -230,19 +230,19 @@ def stream_slices(self) -> Iterable[StreamSlice]:
                     )
 
     def _extract_child_response(
-        self, parent_record: MutableMapping[str, Any], pointer
+        self, parent_record: Mapping[str, Any] | AirbyteMessage, pointer: List[InterpolatedString]
     ) -> requests.Response:
         """Extract child records from a parent record based on lazy pointers."""
 
-        def _create_response(data: Mapping[str, Any]) -> SafeResponse:
+        def _create_response(data: MutableMapping[str, Any]) -> SafeResponse:
             """Create a SafeResponse with the given data."""
             response = SafeResponse()
             response.content = json.dumps(data).encode("utf-8")
             response.status_code = 200
             return response
 
         path = [path.eval(self.config) for path in pointer]
-        return _create_response(dpath.get(parent_record, path, default=[]))
+        return _create_response(dpath.get(parent_record, path, default=[]))  # type: ignore # argunet will be a MutableMapping, given input data structure
 
     def _extract_extra_fields(
         self,